| org.jboss.mq.server |
|
| Java Source File Name | Type | Comment |
| BasicQueue.java | Class | This class represents a queue which provides it's messages exclusively to one
consumer at a time.
Notes about synchronization: Much of the work is synchronized on
the receivers or messages depending on the work performed. |
| BasicQueueParameters.java | Class | |
| ClientConsumer.java | Class | This represent the clients queue which consumes messages from the
destinations on the provider. |
| ClientMonitorInterceptor.java | Class | A pass through Interceptor, which keeps track of when a
client was last active. |
| ExclusiveQueue.java | Class | This class implements a basic queue with an exclusive subscription. |
| JMSDestination.java | Class | |
| JMSDestinationManager.java | Class | |
| JMSQueue.java | Class | |
| JMSServerInterceptor.java | Interface | Interceptor interface for clients IL accessing the JMSServer.
Using an iterface for this layer makes it possible to put in logic
without having to modify the server objet. |
| JMSServerInterceptorSupport.java | Class | A pass through JMSServerInvoker. |
| JMSServerInvoker.java | Class | A pass through JMSServerInvoker. |
| JMSTopic.java | Class | |
| MessageCache.java | Class | This class implements a Message cache so that larger amounts of messages
can be processed without running out of memory. |
| MessageCacheMBean.java | Interface | MBean interface. |
| MessageCounter.java | Class | |
| MessageReference.java | Class | This class holds a reference to an actual Message. |
| NonPersistentInterceptor.java | Class | |
| PersistentQueue.java | Class | This class implements a persistent version of the basic queue. |
| Receivers.java | Interface | Interface to be implemented by a receivers implementation.
The implementation should also have a default constructor.
NOTE: There is no need to internally synchronize the caller
handles that.
NOTE: This datastructure should have Set semantics. |
| ReceiversImpl.java | Class | The default implementation of the Receivers interface. |
| ReceiversImplArrayList.java | Class | The ArrayList implementation of the Receivers interface. |
| ReceiversImplLinkedList.java | Class | The LinkedList implementation of the Receivers interface. |
| RoutedMessage.java | Class | |
| SelectorPersistentQueue.java | Class | This class adds a selector to a persistent queue. |
| TracingInterceptor.java | Class | A pass through Interceptor, wich will trace all calls. |