org.javalite.hornet_nest

Class HornetNest

java.lang.Object

org.javalite.hornet_nest.HornetNest

public class HornetNest
extends Object

Wrapper for embedded HornetQ. It is an embedded in-memory JMS server for asynchronous processing. It can be used in standalone applications, but specifically useful in web apps for processing asynchronous jobs without delaying web responses. It sets many configuration parameters of HornetQ EmbeddedJMS to sensible values so you do not have to. This class also implements a Command Pattern for ease of writing asynchronous code.

Author:

Igor Polevoy on 3/4/15.

Constructor Summary

Constructors

Constructor and Description
HornetNest(String dataDirectory, boolean useLibAio, QueueConfig... queueConfigs) Creates and configures a new instance.

Method Summary

Methods

Modifier and Type	Method and Description
org.hornetq.core.config.Configuration	getConfig() Use to set additional configuration.
org.hornetq.jms.server.config.JMSConfiguration	getJmsConfig() Use to set additional configuration.
void	send(String queueName, Command command) Sends a command into a queue for processing
void	send(String queueName, Command command, int deliveryMode) Sends a command into a queue for processing
void	send(String queueName, Command command, int deliveryMode, int priority, int timeToLive) Sends a command into a queue for processing
void	stop() Stops this JMS server.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HornetNest

public HornetNest(String dataDirectory,
          boolean useLibAio,
          QueueConfig... queueConfigs)

Creates and configures a new instance.

Parameters:

dataDirectory - root directory where persistent messages are stored

useLibAio - true to use libaio, false if not installed. See Libaio Native Libraries

queueConfigs - vararg of QueueConfig> instances.

Method Detail

send

public void send(String queueName,
        Command command)

Sends a command into a queue for processing

Parameters:

queueName - name of queue

command - command instance.

send

public void send(String queueName,
        Command command,
        int deliveryMode)

Sends a command into a queue for processing

Parameters:

queueName - name of queue

command - command to process

deliveryMode - delivery mode: DeliveryMode.

send

public void send(String queueName,
        Command command,
        int deliveryMode,
        int priority,
        int timeToLive)

Sends a command into a queue for processing

Parameters:

queueName - name of queue

command - command to process

deliveryMode - delivery mode: DeliveryMode.

priority - priority of the message. Correct values are from 0 to 9, with higher number denoting a higher priority.

timeToLive - the message's lifetime (in milliseconds, where 0 is to never expire)

stop

public void stop()

Stops this JMS server.

getJmsConfig

public org.hornetq.jms.server.config.JMSConfiguration getJmsConfig()

Use to set additional configuration.

getConfig

public org.hornetq.core.config.Configuration getConfig()

Use to set additional configuration.