activemq-artemis/docs/user-manual/en/embedding-activemq.md

131 lines
4.5 KiB
Markdown
Raw Normal View History

# Embedding Apache ActiveMQ Artemis
Apache ActiveMQ Artemis is designed as set of simple Plain Old Java Objects (POJOs).
This means Apache ActiveMQ Artemis can be instantiated and run in any dependency
2014-12-16 05:27:08 -05:00
injection framework such as Spring or Google Guice. It also means that if you have an application that could use
messaging functionality internally, then it can *directly instantiate*
Apache ActiveMQ Artemis clients and servers in its own application code to perform that
functionality. We call this *embedding* Apache ActiveMQ Artemis.
Examples of applications that might want to do this include any
application that needs very high performance, transactional, persistent
messaging but doesn't want the hassle of writing it all from scratch.
Embedding Apache ActiveMQ Artemis can be done in very few easy steps. Instantiate the
configuration object, instantiate the server, start it, and you have a
Apache ActiveMQ Artemis running in your virtual machine. It's as simple and easy as
that.
2014-12-11 07:17:29 -05:00
## Simple Config File Embedding
The simplest way to embed Apache ActiveMQ Artemis is to use the embedded wrapper
classes and configure Apache ActiveMQ Artemis through its configuration files. There
are two different helper classes for this depending on whether your
using the Apache ActiveMQ Artemis Core API or JMS.
2017-03-09 11:59:09 -05:00
## Embeddeing Apache ActiveMQ Artemis Server
2017-03-09 11:59:09 -05:00
For instantiating a core Apache ActiveMQ Artemis Server, the steps are pretty
simple. The example requires that you have defined a configuration file
2015-04-29 05:30:31 -04:00
`broker.xml` in your classpath:
2014-12-11 07:17:29 -05:00
``` java
import org.apache.activemq.artemis.core.server.embedded.EmbeddedActiveMQ;
2014-12-11 07:17:29 -05:00
...
2014-12-11 07:17:29 -05:00
EmbeddedActiveMQ embedded = new EmbeddedActiveMQ();
2015-01-21 13:27:19 -05:00
2014-12-11 07:17:29 -05:00
embedded.start();
2014-12-11 07:17:29 -05:00
ClientSessionFactory nettyFactory = ActiveMQClient.createClientSessionFactory(
new TransportConfiguration(
InVMConnectorFactory.class.getName()));
2014-12-11 07:17:29 -05:00
ClientSession session = factory.createSession();
2014-12-11 07:17:29 -05:00
session.createQueue("example", "example", true);
2014-12-11 07:17:29 -05:00
ClientProducer producer = session.createProducer("example");
2014-12-11 07:17:29 -05:00
ClientMessage message = session.createMessage(true);
2014-12-11 07:17:29 -05:00
message.getBody().writeString("Hello");
2014-12-11 07:17:29 -05:00
producer.send(message);
2014-12-11 07:17:29 -05:00
session.start();
2014-12-11 07:17:29 -05:00
ClientConsumer consumer = session.createConsumer("example");
2014-12-11 07:17:29 -05:00
ClientMessage msgReceived = consumer.receive();
2014-12-11 07:17:29 -05:00
System.out.println("message = " + msgReceived.getBody().readString());
2014-12-11 07:17:29 -05:00
session.close();
```
The `EmbeddedActiveMQ` class has a few additional setter methods that
allow you to specify a different config file name as well as other
properties. See the javadocs for this class for more details.
2014-12-11 07:17:29 -05:00
## POJO instantiation - Embedding Programmatically
You can follow this step-by-step guide to programmatically embed the
core, non-JMS Apache ActiveMQ Artemis Server instance:
Create the configuration object - this contains configuration
information for an Apache ActiveMQ Artemis instance. The setter methods of this class
allow you to programmatically set configuration options as describe in
2014-12-11 07:17:29 -05:00
the [Server Configuration](configuration-index.md) section.
The acceptors are configured through `ConfigurationImpl`. Just add the
`NettyAcceptorFactory` on the transports the same way you would through
the main configuration file.
2014-12-11 07:17:29 -05:00
``` java
import org.apache.activemq.artemis.core.config.Configuration;
import org.apache.activemq.artemis.core.config.impl.ConfigurationImpl;
2014-12-11 07:17:29 -05:00
...
2014-12-11 07:17:29 -05:00
Configuration config = new ConfigurationImpl();
HashSet<TransportConfiguration> transports = new HashSet<TransportConfiguration>();
2015-02-25 08:37:19 -05:00
2014-12-11 07:17:29 -05:00
transports.add(new TransportConfiguration(NettyAcceptorFactory.class.getName()));
transports.add(new TransportConfiguration(InVMAcceptorFactory.class.getName()));
2014-12-11 07:17:29 -05:00
config.setAcceptorConfigurations(transports);
```
You need to instantiate an instance of
2015-04-29 13:20:31 -04:00
`org.apache.activemq.artemis.api.core.server.embedded.EmbeddedActiveMQ` and add
the configuration object to it.
2014-12-11 07:17:29 -05:00
``` java
import org.apache.activemq.artemis.api.core.server.ActiveMQ;
import org.apache.activemq.artemis.core.server.embedded.EmbeddedActiveMQ;
2014-12-11 07:17:29 -05:00
...
2014-12-11 07:17:29 -05:00
EmbeddedActiveMQ server = new EmbeddedActiveMQ();
server.setConfiguration(config);
2014-12-11 07:17:29 -05:00
server.start();
```
You also have the option of instantiating `ActiveMQServerImpl` directly:
2014-12-11 07:17:29 -05:00
``` java
ActiveMQServer server = new ActiveMQServerImpl(config);
server.start();
```
2014-12-11 07:17:29 -05:00
## Dependency Frameworks
You may also choose to use a dependency injection framework such as
2014-12-16 05:27:08 -05:00
The Spring Framework. See [Spring Integration](spring-integration.md) for more details on
Spring and Apache ActiveMQ Artemis.
Apache ActiveMQ Artemis standalone uses [Airline](https://github.com/airlift/airline) to bootstrap.