Package | Description |
---|---|
org.apache.activemq.broker.util |
Some utility Broker Plugins
|
org.apache.activemq.command |
Command objects used via the Command Pattern to communicate among nodes
|
org.apache.activemq.kaha |
fast message persistence implementation
|
org.apache.activemq.openwire | |
org.apache.activemq.store.amq |
The default Store implementation for ActiveMQ
|
org.apache.activemq.store.jdbc |
Message persistence implemented using JDBC
|
org.apache.activemq.store.journal |
Message persistence using a high performance transaction log via the Journal interface.
|
org.apache.activemq.store.kahadaptor |
kaha implementation of message persistence for the broker
|
org.apache.activemq.transport |
The core Transport abstraction and support classes
|
org.apache.activemq.transport.multicast |
A Multicast based Transport implementation.
|
org.apache.activemq.transport.nio | |
org.apache.activemq.transport.tcp |
TCP/IP based Transport implementation.
|
org.apache.activemq.transport.udp |
UDP based Transport implementation.
|
org.apache.activemq.wireformat |
An API for WireFormats which are used to turn object into bytes and bytes into objects.
|
Modifier and Type | Field and Description |
---|---|
protected WireFormat |
UDPTraceBrokerPlugin.wireFormat |
Modifier and Type | Method and Description |
---|---|
protected WireFormat |
UDPTraceBrokerPlugin.createWireFormat() |
WireFormat |
UDPTraceBrokerPlugin.getWireFormat() |
Modifier and Type | Method and Description |
---|---|
void |
UDPTraceBrokerPlugin.setWireFormat(WireFormat wireFormat) |
Modifier and Type | Method and Description |
---|---|
void |
WireFormatInfo.afterMarshall(WireFormat wireFormat) |
void |
MarshallAware.afterMarshall(WireFormat wireFormat) |
void |
Message.afterMarshall(WireFormat wireFormat) |
void |
WireFormatInfo.afterUnmarshall(WireFormat wireFormat) |
void |
MarshallAware.afterUnmarshall(WireFormat wireFormat) |
void |
Message.afterUnmarshall(WireFormat wireFormat) |
void |
WireFormatInfo.beforeMarshall(WireFormat wireFormat) |
void |
MarshallAware.beforeMarshall(WireFormat wireFormat) |
void |
Message.beforeMarshall(WireFormat wireFormat) |
void |
ActiveMQMapMessage.beforeMarshall(WireFormat wireFormat) |
void |
ActiveMQTextMessage.beforeMarshall(WireFormat wireFormat) |
void |
ActiveMQObjectMessage.beforeMarshall(WireFormat wireFormat) |
void |
WireFormatInfo.beforeUnmarshall(WireFormat wireFormat) |
void |
MarshallAware.beforeUnmarshall(WireFormat wireFormat) |
void |
Message.beforeUnmarshall(WireFormat wireFormat) |
ByteSequence |
WireFormatInfo.getCachedMarshalledForm(WireFormat wireFormat) |
void |
WireFormatInfo.setCachedMarshalledForm(WireFormat wireFormat,
ByteSequence data) |
Constructor and Description |
---|
CommandMarshaller(WireFormat wireFormat) |
MessageMarshaller(WireFormat wireFormat)
Constructor
|
Modifier and Type | Class and Description |
---|---|
class |
OpenWireFormat |
Modifier and Type | Method and Description |
---|---|
WireFormat |
OpenWireFormatFactory.createWireFormat() |
Modifier and Type | Method and Description |
---|---|
WireFormat |
AMQPersistenceAdapter.getWireFormat() |
Modifier and Type | Method and Description |
---|---|
void |
AMQTxOperation.readExternal(WireFormat wireFormat,
DataInput dis) |
void |
AMQPersistenceAdapter.setWireFormat(WireFormat wireFormat) |
void |
AMQTxOperation.writeExternal(WireFormat wireFormat,
DataOutput dos) |
Modifier and Type | Field and Description |
---|---|
protected WireFormat |
JDBCMessageStore.wireFormat |
Modifier and Type | Method and Description |
---|---|
WireFormat |
JDBCPersistenceAdapter.getWireFormat() |
Modifier and Type | Method and Description |
---|---|
void |
JDBCPersistenceAdapter.setWireFormat(WireFormat wireFormat) |
Constructor and Description |
---|
JDBCMessageStore(JDBCPersistenceAdapter persistenceAdapter,
JDBCAdapter adapter,
WireFormat wireFormat,
ActiveMQDestination destination,
ActiveMQMessageAudit audit) |
JDBCPersistenceAdapter(DataSource ds,
WireFormat wireFormat) |
JDBCTopicMessageStore(JDBCPersistenceAdapter persistenceAdapter,
JDBCAdapter adapter,
WireFormat wireFormat,
ActiveMQTopic topic,
ActiveMQMessageAudit audit) |
Modifier and Type | Method and Description |
---|---|
WireFormat |
JournalPersistenceAdapter.getWireFormat() |
Constructor and Description |
---|
AMQTxMarshaller(WireFormat wireFormat) |
TransactionMarshaller(WireFormat wireFormat) |
Modifier and Type | Field and Description |
---|---|
protected WireFormat |
AbstractInactivityMonitor.wireFormat |
Modifier and Type | Method and Description |
---|---|
protected WireFormat |
TransportFactory.createWireFormat(Map<String,String> options) |
Modifier and Type | Method and Description |
---|---|
Transport |
TransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options)
Similar to configure(...) but this avoid adding in the MutexTransport and
ResponseCorrelator transport layers so that the resulting transport can
more efficiently be used as part of a composite transport.
|
Transport |
TransportFactory.configure(Transport transport,
WireFormat wf,
Map options)
Fully configures and adds all need transport filters so that the
transport can be used by the JMS client.
|
protected Transport |
TransportFactory.createTransport(URI location,
WireFormat wf)
Factory method to create a new transport
|
Transport |
TransportFactory.serverConfigure(Transport transport,
WireFormat format,
HashMap options)
Fully configures and adds all need transport filters so that the
transport can be used by the ActiveMQ message broker.
|
Constructor and Description |
---|
AbstractInactivityMonitor(Transport next,
WireFormat wireFormat) |
InactivityMonitor(Transport next,
WireFormat wireFormat) |
MarshallingTransportFilter(Transport next,
WireFormat localWireFormat,
WireFormat remoteWireFormat) |
Modifier and Type | Method and Description |
---|---|
protected Transport |
MulticastTransportFactory.createTransport(URI location,
WireFormat wf) |
Modifier and Type | Method and Description |
---|---|
Transport |
NIOSSLTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options)
Overriding to allow for proper configuration through reflection but delegate to get common
configuration
|
protected TcpTransport |
NIOTransportFactory.createTcpTransport(WireFormat wf,
SocketFactory socketFactory,
URI location,
URI localLocation) |
protected Transport |
NIOSSLTransportFactory.createTransport(URI location,
WireFormat wf)
Overriding to use SslTransports.
|
Constructor and Description |
---|
NIOSSLTransport(WireFormat wireFormat,
Socket socket) |
NIOSSLTransport(WireFormat wireFormat,
SocketFactory socketFactory,
URI remoteLocation,
URI localLocation) |
NIOTransport(WireFormat wireFormat,
Socket socket) |
NIOTransport(WireFormat wireFormat,
SocketFactory socketFactory,
URI remoteLocation,
URI localLocation) |
Modifier and Type | Field and Description |
---|---|
protected WireFormat |
TcpTransport.wireFormat |
Modifier and Type | Method and Description |
---|---|
WireFormat |
TcpTransport.getWireFormat() |
Modifier and Type | Method and Description |
---|---|
Transport |
SslTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options)
Overriding to allow for proper configuration through reflection but delegate to get common
configuration
|
Transport |
TcpTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options) |
protected Transport |
TcpTransportFactory.createInactivityMonitor(Transport transport,
WireFormat format) |
protected TcpTransport |
TcpTransportFactory.createTcpTransport(WireFormat wf,
SocketFactory socketFactory,
URI location,
URI localLocation)
Allows subclasses of TcpTransportFactory to provide a create custom
TcpTransport intances.
|
protected Transport |
TcpTransportServer.createTransport(Socket socket,
WireFormat format)
Allow derived classes to override the Transport implementation that this
transport server creates.
|
protected Transport |
SslTransportServer.createTransport(Socket socket,
WireFormat format)
Used to create Transports for this server.
|
protected Transport |
SslTransportFactory.createTransport(URI location,
WireFormat wf)
Overriding to use SslTransports.
|
protected Transport |
TcpTransportFactory.createTransport(URI location,
WireFormat wf) |
Constructor and Description |
---|
SslTransport(WireFormat wireFormat,
SSLSocket socket)
Initialize from a ServerSocket.
|
SslTransport(WireFormat wireFormat,
SSLSocketFactory socketFactory,
URI remoteLocation,
URI localLocation,
boolean needClientAuth)
Connect to a remote node such as a Broker.
|
TcpTransport(WireFormat wireFormat,
Socket socket)
Initialize from a server Socket
|
TcpTransport(WireFormat wireFormat,
SocketFactory socketFactory,
URI remoteLocation,
URI localLocation)
Connect to a remote Node - e.g.
|
Modifier and Type | Method and Description |
---|---|
protected OpenWireFormat |
UdpTransportFactory.asOpenWireFormat(WireFormat wf) |
Transport |
UdpTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options) |
Transport |
UdpTransportFactory.configure(Transport transport,
WireFormat format,
Map options) |
protected Transport |
UdpTransportFactory.configure(Transport transport,
WireFormat format,
Map options,
boolean acceptServer)
Configures the transport
|
protected Transport |
UdpTransportFactory.configureClientSideNegotiator(Transport transport,
WireFormat format,
UdpTransport udpTransport) |
protected Transport |
UdpTransportFactory.createTransport(int port,
WireFormat wf) |
protected Transport |
UdpTransportFactory.createTransport(URI location,
WireFormat wf) |
Modifier and Type | Class and Description |
---|---|
class |
ObjectStreamWireFormat
A simple implementation which uses Object Stream serialization.
|
Modifier and Type | Method and Description |
---|---|
WireFormat |
WireFormatFactory.createWireFormat() |
Copyright © 2005-2012 Apache Software Foundation. All Rights Reserved.