activemq::transport::tcp::TcpTransport Class Reference
Implements a TCP/IP based transport filter, this transport is meant to wrap an instance of an IOTransport.
More...
#include <src/main/activemq/transport/tcp/TcpTransport.h>
Detailed Description
Implements a TCP/IP based transport filter, this transport is meant to wrap an instance of an IOTransport.
The lower level transport should take care of managing stream reads and writes.
Constructor & Destructor Documentation
Creates a new instance of a TcpTransport, the transport is left unconnected and is in a unusable state until the connect method is called.
- Parameters:
-
| next | The next transport in the chain |
| location | The URI of the host this transport is to connect to. |
| virtual activemq::transport::tcp::TcpTransport::~TcpTransport |
( |
|
) |
[virtual] |
Member Function Documentation
| virtual void activemq::transport::tcp::TcpTransport::afterNextIsStopped |
( |
|
) |
[protected, virtual] |
Subclasses can override this method to do their own stop work.
This method is always called after all the next transports have been stopped to prevent this transport for destroying resources needed by the lower level transports.
Reimplemented from activemq::transport::TransportFilter.
| virtual void activemq::transport::tcp::TcpTransport::beforeNextIsStarted |
( |
|
) |
[protected, virtual] |
Subclasses can override this method to do their own startup work.
This method will always be called before the next transport in the chain is called in order to allow this transport a chance to initialize required resources.
Reimplemented from activemq::transport::TransportFilter.
| virtual void activemq::transport::tcp::TcpTransport::configureSocket |
( |
decaf::net::Socket * |
socket |
) |
[protected, virtual] |
Using options from configuration URI, configure the socket options before the Socket instance is connected to the Server.
Subclasses can override this option to set more configuration options, they should called the base class version to allow the default set of Socket options to also be configured.
- Parameters:
-
| socket | The Socket instance to configure using options from the given Properties. |
- Exceptions:
-
| NullPointerException | if the Socket instance is null. |
| IllegalArgumentException | if the socket instance is not handled by the class. |
| SocketException | if there is an error while setting one of the Socket options. |
Reimplemented in activemq::transport::tcp::SslTransport.
| void activemq::transport::tcp::TcpTransport::connect |
( |
|
) |
[protected] |
Creates a Socket and configures it before attempting to connect to the location specified by the URI passed in.
| virtual decaf::net::Socket* activemq::transport::tcp::TcpTransport::createSocket |
( |
|
) |
[protected, virtual] |
Create an unconnected Socket instance to be used by the transport to communicate with the broker.
- Returns:
- a newly created unconnected Socket instance.
- Exceptions:
-
| IOException | if there is an error while creating the unconnected Socket. |
Reimplemented in activemq::transport::tcp::SslTransport.
| virtual void activemq::transport::tcp::TcpTransport::doClose |
( |
|
) |
[protected, virtual] |
Subclasses can override this method to do their own close work.
This method is always called after all the next transports have been closed to prevent this transport for destroying resources needed by the lower level transports.
Reimplemented from activemq::transport::TransportFilter.
| int activemq::transport::tcp::TcpTransport::getConnectTimeout |
( |
|
) |
const |
| int activemq::transport::tcp::TcpTransport::getInputBufferSize |
( |
|
) |
const |
| int activemq::transport::tcp::TcpTransport::getLinger |
( |
|
) |
const |
| decaf::net::URI activemq::transport::tcp::TcpTransport::getLocation |
( |
|
) |
const [protected] |
| int activemq::transport::tcp::TcpTransport::getOutputBufferSize |
( |
|
) |
const |
| int activemq::transport::tcp::TcpTransport::getReceiveBufferSize |
( |
|
) |
const |
| int activemq::transport::tcp::TcpTransport::getSendBufferSize |
( |
|
) |
const |
| virtual bool activemq::transport::tcp::TcpTransport::isConnected |
( |
|
) |
const [virtual] |
| virtual bool activemq::transport::tcp::TcpTransport::isFaultTolerant |
( |
|
) |
const [inline, virtual] |
| bool activemq::transport::tcp::TcpTransport::isKeepAlive |
( |
|
) |
const |
| bool activemq::transport::tcp::TcpTransport::isTcpNoDelay |
( |
|
) |
const |
| bool activemq::transport::tcp::TcpTransport::isTrace |
( |
|
) |
const |
| void activemq::transport::tcp::TcpTransport::setConnectTimeout |
( |
int |
soConnectTimeout |
) |
|
| void activemq::transport::tcp::TcpTransport::setInputBufferSize |
( |
int |
inputBufferSize |
) |
|
| void activemq::transport::tcp::TcpTransport::setKeepAlive |
( |
bool |
soKeepAlive |
) |
|
| void activemq::transport::tcp::TcpTransport::setLinger |
( |
int |
soLinger |
) |
|
| void activemq::transport::tcp::TcpTransport::setOutputBufferSize |
( |
int |
outputBufferSize |
) |
|
| void activemq::transport::tcp::TcpTransport::setReceiveBufferSize |
( |
int |
soReceiveBufferSize |
) |
|
| void activemq::transport::tcp::TcpTransport::setSendBufferSize |
( |
int |
soSendBufferSize |
) |
|
| void activemq::transport::tcp::TcpTransport::setTcpNoDelay |
( |
bool |
tcpNoDelay |
) |
|
| void activemq::transport::tcp::TcpTransport::setTrace |
( |
bool |
trace |
) |
|
The documentation for this class was generated from the following file:
