18#ifndef _ACTIVEMQ_TRANSPORT_TCP_TCPTRANSPORT_H_
19#define _ACTIVEMQ_TRANSPORT_TCP_TCPTRANSPORT_H_
39 using decaf::lang::Pointer;
41 class TcpTransportImpl;
51 TcpTransportImpl* impl;
55 TcpTransport(
const TcpTransport&);
56 TcpTransport& operator=(
const TcpTransport&);
#define AMQCPP_API
Definition Config.h:30
Pointer< Transport > next
The transport that this filter wraps around.
Definition TransportFilter.h:54
void setTcpNoDelay(bool tcpNoDelay)
int getOutputBufferSize() const
void setConnectTimeout(int soConnectTimeout)
void connect()
Creates a Socket and configures it before attempting to connect to the location specified by the URI ...
int getInputBufferSize() const
virtual void configureSocket(decaf::net::Socket *socket)
Using options from configuration URI, configure the socket options before the Socket instance is conn...
virtual bool isFaultTolerant() const
Is this Transport fault tolerant, meaning that it will reconnect to a broker on disconnect.
Definition TcpTransport.h:102
void setTrace(bool trace)
void setReceiveBufferSize(int soReceiveBufferSize)
int getReceiveBufferSize() const
void setLinger(int soLinger)
virtual void beforeNextIsStarted()
Subclasses can override this method to do their own startup work.
void setKeepAlive(bool soKeepAlive)
TcpTransport(const Pointer< Transport > next, const decaf::net::URI &location)
Creates a new instance of a TcpTransport, the transport is left unconnected and is in a unusable stat...
bool isTcpNoDelay() const
void setOutputBufferSize(int outputBufferSize)
decaf::net::URI getLocation() const
virtual void afterNextIsStopped()
Subclasses can override this method to do their own stop work.
int getSendBufferSize() const
int getConnectTimeout() const
virtual bool isConnected() const
Is the Transport Connected to its Broker.
void setSendBufferSize(int soSendBufferSize)
void setInputBufferSize(int inputBufferSize)
virtual void doClose()
Subclasses can override this method to do their own close work.
virtual decaf::net::Socket * createSocket()
Create an unconnected Socket instance to be used by the transport to communicate with the broker.
Decaf's implementation of a Smart Pointer that is a template on a Type and is Thread Safe if the defa...
Definition Pointer.h:53
This class represents an instance of a URI as defined by RFC 2396.
Definition URI.h:37
Definition SslTransport.h:27
Definition AbstractTransportFactory.h:30
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
Definition CachedConsumer.h:24