|
||||||||||
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 destinationsDestinationInterceptor
Destination
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.DestinationMap
DestinationMap
treeReliableTransportChannel
which uses a DiscoveryAgent
to
discover remote broker instances and dynamically connect to them.acknowledgeMode
property *
subscriptionDurability
property *
MessageGroupSet
SubscriptionRecoveryPolicy
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.NameParser
subscriptionDurability
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.MessageProducer
SubscriptionRecoveryPolicy
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 libraryReplayBuffer
ReplayBuffer
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.Set
MessageList
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/ipTransportServer
SubscriptionRecoveryPolicy
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
.TransportServer
TransportServer
which uses
a background thread to accept new connections.Transport
interface using raw UDPTransportServer
MessageEndpoint.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 |