All Classes and Interfaces
Class
Description
Base implementation of
Constant.Proxy to intercept asynchronous callbacks and executes them on the stream's event queue
At Timer implementation.
Facade to wrap a javax.jms.BytesMessage.
Executor class for CLI commands.
An
Exception which is thrown by a codec.A singleton which is safe to compare via the
== operator.A pool of
Constants.A CountLimit keeps a Memory at a specific number of Messages and removes
older Messages if necessary.
An
CodecException which is thrown by a decoder.Intermediate interface to separate JMS destination inputs.
Facade to send an eMail.
Callback that can be registered on the Stream (onException).
Callback that can be registered on the forEach() method of a MemoryGroup or a GroupResult.
Callback that can be registered on the forEach() method of a Memory.
Callback that can be registered on the forEach() method of a PropertySet.
A GroupInactivityTimeout can be
attached to a MemoryGroup and specifies a time of inactivity (no adds to attached Memory)
after which all Messages in that Memory will retire and the Memory will be closed and
removed from the MemoryGroup.
Represents the result of a group operation on a Memory.
Memory implementation that stores all Messages on the heap.
InactivityTimeout can be attached to a Memory and specifies a time of inactivity (no adds to Memory)
after which all Messages in that Memory will retire.
Property Index that helds Property Values and References to Messages.
Base interface for Inputs.
Factory to create Inputs.
Callback that can be registered on an Input (onInput).
Interval Timer implementation.
Facade to perform queries on a JDBC connected database.
Base interface for Memory Limits.
Factory to create Memory Limits.
Represents the Stream's log file.
Represents a Connection to a Mail Server.
Consumes Messages from the Management Tree.
Facade to wrap the body of a javax.jms.MapMessage
Facade to wrap a javax.jms.MapMessage
Facade to wrap the Value of a Map Body
Abstract base class for Memories.
Factory to create Memories.
Callback that is registered at a MemoryGroup.
A MemoryGroup groups incoming Messages on base of the values of a Message Property (Group Property).
Callback that is registered at a MemoryGroup.
Facade to wrap a javax.jms.Message.
Factory to create Message facades.
See MQTTV3.1/connack
Variable header of
MqttConnectMessageSee MQTTV3.1/connect
Payload of
MqttConnectMessageReturn Code of
MqttConnAckMessageVariable Header for the
MqttConnectMessageDecodes Mqtt messages from bytes, following
the MQTT protocol specification v3.1
Encodes Mqtt messages into bytes following the protocol specification v3.1
as described here MQTTV3.1
A
MqttIdentifierRejectedException which is thrown when a CONNECT request contains invalid client identifier.Base class for all MQTT message types.
Utility class with factory methods to create different types of MQTT messages.
Variable Header containing only Message Id
See MQTTV3.1/msg-id
MQTT Message Types.
See MQTTV3.1/puback
See MQTTV3.1/publish
Variable Header of the
MqttPublishMessageSee MQTTV3.1/suback
Payload of the
MqttSubAckMessagePayload of the
MqttSubscribeMessageContains a topic name and Qos Level.
A
MqttUnacceptableProtocolVersionException which is thrown when
a CONNECT request contains unacceptable protocol version.Payload of the
MqttUnsubscribeMessageMqtt version specific constant values used by multiple classes in mqtt-codec.
Next Timer implementation.
Facade to wrap a javax.jms.ObjectMessage.
A grab-bag of useful utility methods.
Convenience class that provides methods to access environment properties.
Represents an Output to a Queue or Topic.
Factory to create Outputs.
Encapsulates the Parameters for a Script
Facade to wrap the Property of a javax.jms.Message
Facade to wrap a Set of Properties of a javax.jms.Message
Facade to wrap the Value of a Message Property
Consumes Messages from a Queue.
Memory implementation that stores all Messages as persistent Messages in a regular Queue.
Sends Messages to a Queue.
Creates or re-uses a named WireTap on a Queue and adds a subscriber to it.
Callback that can be registered on a Memory.
A special
Error which is used to signal some state or request by throwing it.Stream is the entry point for SwiftMQ Streams.
Facade to wrap the body of a javax.jms.StreamMessage
Factory to create Stream resources.
Facade to wrap a javax.jms.StreamMessage.
String utility class.
Memory implementation that stores all Messages as non-persistent Messages in a Temporary Queue.
Facade to wrap a javax.jms.TextMessage.
A TimeLimit keeps a Memory at a specific time window (e.g.
Base interface for Timers.
Factory to create Timers.
Callback that can be registered on a Timer (onTimer).
Convenience class that provides various time methods.
A TimeUnitChangeLimit keeps a Memory at a specific time unit window (e.g.
Consumes Messages from a Topic.
Sends Messages to a Topic.
TransactionId covers type of transaction and internal id
Convenience class to convert an object into various basic types.