|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
BytesMessage object is used to send a message containing a stream of uninterpreted bytes.ActiveMQConnection
Connection objects provide a special
facility for creating a ConnectionConsumer (optional).ConnectionMetaData object provides information describing
the Connection object.ConnectionFactory
instances as well as a child context called destinations which contain all of the
current active destinations, in child context depending on the QoS such as
transient or durable and queue or topic.MapMessage object is used to send a set of name-value pairs.MessageConsumer object to receive messages
from a destination.MessageProducer object to send messages to a
destination.ObjectMessage object is used to send a message that contains a serializable object in the Java
programming language ("Java object").QueueBrowser object to look at messages on a
queue without removing them.QueueReceiver object to receive messages that
have been delivered to a queue.QueueSender object to send messages to a
queue.Session object is a single-threaded context for producing
and consuming messages.StreamMessage object is used to send a stream of primitive
types in the Java programming language.TopicPublisher object to publish messages on
a topic.TopicSubscriber object to receive messages
that have been published to a topic.InitialContextFactory should be used
when ActiveMQ is used as WebSphere Generic JMS Provider.XAConnection instancesDestinationNode which navigates all the children of the given node
ignoring the name of the current path (so for navigating using * in a wildcard).DefaultAuthorizationMap for assigning
different operations (read, write, admin) of user roles to a specific
destination or a hierarchical wildcard area of destinations.acknowledgeMode property
Queue so that they can be dispatched
by the HTTP GET requests from the client.FactoryBean which creates an embedded broker inside a Spring
XML using an external XBean Spring XML
configuration file which provides a much neater and more concise XML
format.BrokerService
to be injectedByteBuffer instances.TransactionTemplate
and org.apache.activemq.util.ExceptionTemplate
objects to provide automatic transactional or exception handling blocks.Command.getCommandId()DestinationFilter used for composite destinationsDestinationInterceptorDestination where send()s are replicated to
each Destination instance.QueueBrowser object to peek at the messages on
the specified queue.
QueueBrowser object to peek at the messages on
the specified queue using a message selector.
BytesMessage object.
MessageConsumer for the specified destination.
MessageConsumer for the specified destination,
using a message selector.
MessageConsumer for the specified destination,
using a message selector.
MapMessage object.
Message object.
ObjectMessage object.
ObjectMessage object.
MessageProducer to send messages to the
specified destination.
Queue name.
QueueSession object.
QueueReceiver object to receive messages from
the specified queue.
QueueReceiver object to receive messages from
the specified queue using a message selector.
QueueSender object to send messages to the
specified queue.
Session object.
StreamMessage object.
TemporaryQueue object.
TemporaryTopic object.
TextMessage object.
TextMessage object.
Topic name.
TopicSession object.
StoreByteArrayInputStream.
StoreByteArrayInputStream.
WireByteArrayInputStream with a minmalist byte array
BufferPool which keeps a pool of direct
byte buffers.MessageList which maintains a separate message
list for each destination to reduce contention on the list and to speed up
recovery times by only recovering the interested topics.Destination.ActiveMQDestination and retrieved by destination - supporting both *
and > style of wildcard as well as composite destinations.DestinationMapDestinationMap treeReliableTransportChannel which uses a DiscoveryAgent to
discover remote broker instances and dynamically connect to them.acknowledgeMode property *
subscriptionDurability property *
MessageGroupSetSubscriptionRecoveryPolicy will keep a fixed count
of last messages.SubscriptionRecoveryPolicy will keep a fixed
amount of memory available in RAM for message history which is evicted in
time order.put into this object.
InboundContext used by the current thread which is processing a message.
MessageConsumer.receiveNoWait() can be called.
boolean value with the specified name.
byte value with the specified name.
MessageProducer.
ActiveMQDestination
objects that the persistence store is aware exist.
ActiveMQDestination
objects that the persistence store is aware exist.
double value with the specified name.
DestinationMap.setEntries(List) method.
ExceptionListener object for this connection.
float value with the specified name.
int value with the specified name.
long value with the specified name.
Enumeration of all the names in the MapMessage object.
MessageListener.
foobar .
NoLocal attribute for this subscriber.
foobar._http._tcp.local. .
Queue associated with this queue receiver.
QueueSender.
timeout timeout ms to get a receipt
short value with the specified name.
String value with the specified name.
TopicPublisher.
Topic associated with this subscriber.
_http._tcp.local. .
org.apache.activemq.transport.TransportChannel which uses the commons-httpclient
libraryConnection implementation which can be used with the ActiveMQ JCA
Resource Adapter to publish messages using the same JMS session that is used to dispatch
messages.ConnectionFactory implementation which creates connections which can
be used with the ActiveMQ JCA Resource Adapter to publish messages using the
same underlying JMS session that is used to dispatch messages.Session instance and
an optional, lazily created MessageProducer instance
which can them be used by a pooling based JMS provider for publishing
messages using the session used by the current thread.InboundContext instance being used to process a message
in the current thread so that messages can be produced using the same
session.MessageProducer which uses the ActiveMQ JCA ResourceAdapter's
current thread's JMS Session to send messages.Session implementation which can be used with the ActiveMQ JCA
Resource Adapter to publish messages using the same JMS session that is used to dispatch
messages.DeadLetterStrategy where each destination has its own individual
DLQ using the subject naming hierarchy.null as its detail message.
MapMessage object.
PersistenceAdapter implementation using JDBC for persistence
storage.Destination as well.MessageProducer or MessageConsumer as it passes in a
Session parent statistic.
Destination
PersistenceAdapter designed for use with a
Journal and then check pointing asynchronously on a timeout with some
other long term persistent storage.MessageStore which uses a JPS ContainerSubscriptionRecoveryPolicy will only keep
the last message.PartialCommand instances.AuthorizationMap which uses LDAPMessageStore which uses aMessage objectsSimpleMessageGroupMap when
implementing the Message
Groups functionality.MessageGroupMap
for a destination.org.apache.activemq.service.MessageContainer
implementationsDiscoveryAgent using a multicast address and heartbeat packets encoded using any
wireformat, but openwire by default.Transport instance such as when using multicast.NameParsersubscriptionDurability property *
MessageBuffer which evicts messages in arrival order so the oldest
messages are removed first.PolicyMap for assigning policies to a
specific destination or a hierarchical wildcard area of destinations.Connection which is-a TopicConnection and
QueueConnection which is pooled and on PooledConnection.close() will return
itself to the sessionPool.MessageProducerSubscriptionRecoveryPolicy will perform a user
specific query mechanism to load any messages they may have missed.PersistenceAdapter designed for use with a
Journal and then check pointing asynchronously on a timeout with some
other long term persistent storage.PersistenceAdapter designed for use with a
Journal and then check pointing asynchronously on a timeout with some
other long term persistent storage.len bytes of data into an array of bytes from this input stream.
boolean from the bytes message stream.
boolean from the stream message.
byte value from the stream message.
byte[] object (the read buffer).
double from the bytes message stream.
double from the stream message.
float from the bytes message stream.
float from the stream message.
String from the stream message.
MessageEndpoint.beforeDelivery(java.lang.reflect.Method)
method is called.
DiscoveryAgent using Zeroconf
via the jmDNS libraryReplayBufferReplayBuffer to replay buffers back over an unreliable transportStoreByteArrayInputStream to use an new byte array
StoreByteArrayInputStream to use an new ByteSequence
MessageProducer's default
delivery mode, priority, and time to live.
TransportAcceptListener which is notified of accepted channels.
MessageConsumer.receiveNoWait() can be called.
MessageConsumer.receiveNoWait() can be called.
boolean value with the specified name into the Map.
byte value with the specified name into the Map.
double value with the specified name into the Map.
float value with the specified name into the Map.
int value with the specified name into the Map.
long value with the specified name into the Map.
MessageListener.
SslTransportServer.bind()
Note: Calling this method clears the wantClientAuth flag
in the underlying implementation.
multicast://address:port
MasterConnector
short value with the specified name into the Map.
String value with the specified name into the Map.
TransportServer configured via the
TransportConnector.setServer(TransportServer) method.
DeadLetterStrategy which uses
a constant destination.BufferPool which does no pooling and just
creates new buffers each timeSimpleMessageGroupMap when implementing the
Message Groups functionality.SetMessageList where there is a single, fixed size
list that all messages are added to for simplicity.MessageBuffer which evicts from the largest buffers first.Transport interface using raw tcp/ipTransportServerSubscriptionRecoveryPolicy will keep a timed
buffer of messages around in memory and use that to recover new
subscriptions.Transport objects
and then delivers those objects to a TransportAcceptListener.TransportServerTransportServer which uses
a background thread to accept new connections.Transport interface using raw UDPTransportServerMessageEndpoint.afterDelivery()
method is called.
len bytes from the specified byte array starting at offset off to this byte
array output stream.
boolean to the bytes message stream as a 1-byte value.
boolean to the stream message.
byte to the bytes message stream as a 1-byte value.
byte to the stream message.
char to the bytes message stream as a 2-byte value, high byte first.
char to the stream message.
double argument to a long using the doubleToLongBits method
in class Double, and then writes that long value to the bytes message stream as an
8-byte quantity, high byte first.
double to the stream message.
float argument to an int using the floatToIntBits method in
class Float, and then writes that int value to the bytes message stream as a 4-byte
quantity, high byte first.
float to the stream message.
int to the bytes message stream as four bytes, high byte first.
int to the stream message.
long to the bytes message stream as eight bytes, high byte first.
long to the stream message.
short to the bytes message stream as two bytes, high byte first.
short to the stream message.
String to the stream message.
WireFormat implementation which uses the XStreamWireFormat() -
Constructor for class org.apache.activemq.transport.xstream.XStreamWireFormat
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||