Class DummyTransport.DummyTransportResponder

java.lang.Object

org.snmp4j.transport.AbstractTransportMapping<A>

org.snmp4j.transport.DummyTransport.DummyTransportResponder

All Implemented Interfaces:

Closeable, AutoCloseable, TransportMapping<A>

Enclosing class:

DummyTransport<A extends IpAddress>

public class DummyTransport.DummyTransportResponder
extends AbstractTransportMapping<A>

Since:

2.0

Author:

Frank Fock

Field Summary

Fields inherited from class AbstractTransportMapping

asyncMsgProcessingSupported, connectionTimeout, listenWorkerTask, maxInboundMessageSize, socketCleaner, suspendedAddresses, transportAuditListeners, transportListener, transportStateListeners

Constructor Summary

Constructors

Constructor	Description
DummyTransportResponder()

Method Summary

Modifier and Type	Method	Description
void	close()	Closes this resource and releases any associated system resources.
A	getListenAddress()	Returns the address that represents the actual incoming address this transport mapping uses to listen for incoming packets.
WorkerTask	getListenWorkerTask()	Gets the WorkerTask that is responsible for receiving new messages.
Class<? extends Address>	getSupportedAddressClass()	Gets the primary Address class that is supported by this transport mapping.
boolean	isListening()	Returns true if the transport mapping is listening for incoming messages.
void	listen()	Starts listening for incoming connections or events.
void	sendMessage(A address, byte[] message, TransportStateReference tmStateReference, long timeoutMillis, int retries)	Sends a message to the supplied address using this transport.

Methods inherited from class AbstractTransportMapping

addTransportAuditListener, addTransportListener, addTransportStateListener, fireConnectionStateChanged, fireProcessMessage, fireTransportAuditEvent, getAuditListenAddress, getMaxInboundMessageSize, getPriority, getSocketCleaner, getSuspendedAddresses, getThreadName, handleDroppedMessageToSend, isAsyncMsgProcessingSupported, isTransportAudit, removeAllTransportAuditListeners, removeAllTransportListeners, removeTransportAuditListener, removeTransportListener, removeTransportStateListener, resumeAddress, setAsyncMsgProcessingSupported, setPriority, setThreadName, suspendAddress

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface TransportMapping

getMaxOutboundMessageSize, getSupportedAddressClasses, getSupportedTransportType, isAddressSupported, isAddressSupported

Constructor Details

DummyTransportResponder

public DummyTransportResponder()

Method Details

getSupportedAddressClass

public Class<? extends Address> getSupportedAddressClass()

Description copied from interface: TransportMapping

Gets the primary Address class that is supported by this transport mapping.

Specified by:

getSupportedAddressClass in interface TransportMapping<A extends IpAddress>

Specified by:

getSupportedAddressClass in class AbstractTransportMapping<A extends IpAddress>

Returns:

a subclass of Address.

getListenAddress

public A getListenAddress()

Description copied from interface: TransportMapping

Returns the address that represents the actual incoming address this transport mapping uses to listen for incoming packets.

Specified by:

getListenAddress in interface TransportMapping<A extends IpAddress>

Specified by:

getListenAddress in class AbstractTransportMapping<A extends IpAddress>

Returns:

the address for incoming packets or null this transport mapping is not configured to listen for incoming packets.

sendMessage

public void sendMessage(A address,
 byte[] message,
 TransportStateReference tmStateReference,
 long timeoutMillis,
 int retries)
                 throws IOException

Description copied from class: AbstractTransportMapping

Sends a message to the supplied address using this transport. If the target address has been suspended, then instead actually sending the message on the wire, the method AbstractTransportMapping.handleDroppedMessageToSend(Address, byte[], TransportStateReference, long, int) will be called. To stop suspending of a target address, call AbstractTransportMapping.resumeAddress(Address) for that address.

Specified by:

sendMessage in interface TransportMapping<A extends IpAddress>

Specified by:

sendMessage in class AbstractTransportMapping<A extends IpAddress>

Parameters:

address - an Address instance denoting the target address.

message - the whole message as an array of bytes.

tmStateReference - the (optional) transport model state reference as defined by RFC 5590 section 6.1.

timeoutMillis - maximum number of milliseconds the connection creation might take (if connection-based).

retries - maximum retries during connection creation.

Throws:

IOException - if any underlying IO operation fails.

close

public void close()
           throws IOException

Description copied from class: AbstractTransportMapping

Closes this resource and releases any associated system resources. If the resource is already closed, invoking this method has no effect.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface TransportMapping<A extends IpAddress>

Specified by:

close in class AbstractTransportMapping<A extends IpAddress>

Throws:

IOException - if an I/O error occurs while closing the resource

listen

public void listen()
            throws IOException

Description copied from class: AbstractTransportMapping

Starts listening for incoming connections or events. This method is intended to be implemented by subclasses to define the specific behavior required for listening operations in various contexts (e.g., network connections, event streams).

Specified by:

listen in interface TransportMapping<A extends IpAddress>

Specified by:

listen in class AbstractTransportMapping<A extends IpAddress>

Throws:

IOException - if an I/O error occurs during the listening process.

getListenWorkerTask

public WorkerTask getListenWorkerTask()

Description copied from class: AbstractTransportMapping

Gets the WorkerTask that is responsible for receiving new messages.

Overrides:

getListenWorkerTask in class AbstractTransportMapping<A extends IpAddress>

Returns:

a WorkerTask instance which is most likely a DefaultThreadFactory.WorkerThread.

isListening

public boolean isListening()

Description copied from interface: TransportMapping

Returns true if the transport mapping is listening for incoming messages. For connection oriented transport mappings this is a prerequisite to be able to send SNMP messages. For connectionless transport mappings it is a prerequisite to be able to receive responses.

Specified by:

isListening in interface TransportMapping<A extends IpAddress>

Overrides:

isListening in class AbstractTransportMapping<A extends IpAddress>

Returns:

true if this transport mapping is listening for messages.