public class SyncPipelineConnection extends PipelineConnectionBase
PipelineConnectionBase
extension.PipelineConnectionBase.ResponseHandler
Connection.Event, Connection.Factory, Connection.Flag, Connection.Listener, Connection.Modality, Connection.Property, Connection.Socket, Connection.State
spec
Constructor and Description |
---|
SyncPipelineConnection(ConnectionSpec spec) |
Modifier and Type | Method and Description |
---|---|
Response |
serviceRequest(Command cmd,
byte[]... args)
A blocking call to service the specified request.
|
initializeComponents, newInputStream, newProtocolHandler, notifyConnected, notifyDisconnected, queueRequest
addListener, connect, disconnect, getInputStream, getOutputStream, getProtocolHandler, getSpec, initializeAsyncConnection, initializeOnConnect, initializeSocketStreams, initializeSyncConnection, isConnected, newOutputStream, notifyFaulted, notifyListeners, notifyShuttingDown, onConnectionFault, reconnect, removeListener, shutdown, toString
public SyncPipelineConnection(ConnectionSpec spec) throws ClientRuntimeException
spec
- ClientRuntimeException
public Response serviceRequest(Command cmd, byte[]... args) throws RedisException, ClientRuntimeException, ProviderException
Connection
Protocol
interface
and can (and should) be addressed at the implementation level (for example when creating
handler instances using a specification set, including max wait for synchronous response.)
Connection.Modality.Asynchronous
handlers must always throw a ClientRuntimeException
for this method which violates the contract for Connection.Modality.Asynchronous
handlers.
serviceRequest
in interface Connection
serviceRequest
in class ConnectionBase
RedisException
ClientRuntimeException
ProviderException
Copyright © 2009–2016. All rights reserved.