public interface TransportHandler
Modifier and Type | Field and Description |
---|---|
static String |
EXTRA_URI_PARMS_RESOURCE |
static String |
UNSUPPORTED_MESSAGE_NO_CLIENT_SUPPORT |
static String |
UNSUPPORTED_MESSAGE_NO_SERVER_SUPPORT |
Modifier and Type | Method and Description |
---|---|
void |
close()
Permanently closes this transport handler.
|
void |
configure(Message capabilitiesMessage)
Called to configure the transport.
|
TransportStatistics |
getStatistics()
Returns the
TransportStatistics instance. |
void |
handleProtocolExtension(Message message)
Allows extension to the standard ErraiBus Protocol by optionally handling any unknown protocol verbs from the
wire.
|
boolean |
isUsable()
Indicates whether the transport is usable.
|
void |
start()
Called to start the transport.
|
Collection<Message> |
stop(boolean stopAllCurrentRequests)
Called to stop the transport.
|
void |
transmit(List<Message> txMessages)
Transmits the specified list of
Message to the remote bus over the transport. |
static final String EXTRA_URI_PARMS_RESOURCE
static final String UNSUPPORTED_MESSAGE_NO_SERVER_SUPPORT
static final String UNSUPPORTED_MESSAGE_NO_CLIENT_SUPPORT
void configure(Message capabilitiesMessage)
capabilitiesMessage
- the capabilities message from the message bus on handshake.void start()
Collection<Message> stop(boolean stopAllCurrentRequests)
stopAllCurrentRequests
- specifying true will cause any in-flight messages which have not returned to be immediately
cancelled.void transmit(List<Message> txMessages)
Message
to the remote bus over the transport.txMessages
- a list of Message
to be transmitted.void handleProtocolExtension(Message message)
message
- boolean isUsable()
TransportStatistics getStatistics()
TransportStatistics
instance.void close()
Copyright © 2013-2015 JBoss, a division of Red Hat. All Rights Reserved.