public abstract class TcpTransportMapping extends AbstractTransportMapping implements ConnectionOrientedTransportMapping
TcpTransportMapping is the abstract base class for
TCP transport mappings.| Modifier and Type | Field and Description |
|---|---|
protected TcpAddress |
tcpAddress |
asyncMsgProcessingSupported, maxInboundMessageSize, transportListener| Constructor and Description |
|---|
TcpTransportMapping(TcpAddress tcpAddress) |
| Modifier and Type | Method and Description |
|---|---|
void |
addTransportStateListener(TransportStateListener l)
Adds a transport state listener that is to be informed about connection
state changes.
|
abstract void |
close()
Closes the transport an releases all bound resources synchronously.
|
protected void |
fireConnectionStateChanged(TransportStateEvent change) |
TcpAddress |
getAddress()
Returns the transport address that is used by this transport mapping for
sending and receiving messages.
|
Address |
getListenAddress()
Returns the address that represents the incoming address this transport
mapping uses to listen for incoming packets.
|
abstract MessageLengthDecoder |
getMessageLengthDecoder()
Returns the
MessageLengthDecoder used by this transport
mapping. |
Class |
getSupportedAddressClass()
Gets the
Address class that is this transport mapping
supports. |
abstract void |
listen()
Listen for incoming messages.
|
void |
removeTransportStateListener(TransportStateListener l)
Removes the supplied transport state listener.
|
abstract void |
sendMessage(Address address,
byte[] message)
Sends a message to the supplied address using this transport.
|
abstract void |
setConnectionTimeout(long connectionTimeout)
Sets the connection timeout.
|
abstract void |
setMessageLengthDecoder(MessageLengthDecoder messageLengthDecoder)
Sets the
MessageLengthDecoder that decodes the total
message length from the header of a message. |
addMessageDispatcher, addTransportListener, fireProcessMessage, getMaxInboundMessageSize, isAsyncMsgProcessingSupported, removeMessageDispatcher, removeTransportListener, setAsyncMsgProcessingSupportedclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitcloseaddMessageDispatcher, addTransportListener, getMaxInboundMessageSize, isListening, removeMessageDispatcher, removeTransportListenerprotected TcpAddress tcpAddress
public TcpTransportMapping(TcpAddress tcpAddress)
public Class getSupportedAddressClass()
TransportMappingAddress class that is this transport mapping
supports.getSupportedAddressClass in interface TransportMappinggetSupportedAddressClass in class AbstractTransportMappingAddress.public TcpAddress getAddress()
Address used by this transport mapping. The returned
instance must not be modified!public Address getListenAddress()
TransportMappinggetListenAddress in interface TransportMappingnull this transport
mapping is not configured to listen for incoming packets.public abstract void sendMessage(Address address, byte[] message) throws IOException
TransportMappingsendMessage in interface TransportMappingsendMessage in class AbstractTransportMappingaddress - an Address instance denoting the target address.message - the whole message as an array of bytes.IOExceptionpublic abstract void listen()
throws IOException
TransportMappingTransportMapping.sendMessage(org.snmp4j.smi.Address, byte[]) is called for the
first time.listen in interface TransportMappinglisten in class AbstractTransportMappingIOExceptionpublic abstract void close()
throws IOException
TransportMappingclose in interface TransportMappingclose in class AbstractTransportMappingIOExceptionpublic abstract MessageLengthDecoder getMessageLengthDecoder()
MessageLengthDecoder used by this transport
mapping.getMessageLengthDecoder in interface ConnectionOrientedTransportMappingpublic abstract void setMessageLengthDecoder(MessageLengthDecoder messageLengthDecoder)
MessageLengthDecoder that decodes the total
message length from the header of a message.setMessageLengthDecoder in interface ConnectionOrientedTransportMappingmessageLengthDecoder - a MessageLengthDecoder instance.public abstract void setConnectionTimeout(long connectionTimeout)
setConnectionTimeout in interface ConnectionOrientedTransportMappingconnectionTimeout - the idle timeout in milliseconds. A zero or negative value will disable
any timeout and connections opened by this transport mapping will stay
opened until they are explicitly closed.public void addTransportStateListener(TransportStateListener l)
ConnectionOrientedTransportMappingaddTransportStateListener in interface ConnectionOrientedTransportMappingl - a TransportStateListener.public void removeTransportStateListener(TransportStateListener l)
ConnectionOrientedTransportMappingremoveTransportStateListener in interface ConnectionOrientedTransportMappingl - a TransportStateListener.protected void fireConnectionStateChanged(TransportStateEvent change)
Copyright © 2014 SNMP4J.org. All rights reserved.