You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by de...@apache.org on 2013/07/12 14:46:31 UTC
svn commit: r869232 [14/44] - in /websites/production/activemq/content: ./
cache/ cms/ nms/ styles/highlighter/ styles/highlighter/scripts/
styles/highlighter/styles/ visualisation.thumbs/ web-console.thumbs/
Modified: websites/production/activemq/content/how-should-i-implement-request-response-with-jms.html
==============================================================================
--- websites/production/activemq/content/how-should-i-implement-request-response-with-jms.html (original)
+++ websites/production/activemq/content/how-should-i-implement-request-response-with-jms.html Fri Jul 12 12:46:14 2013
@@ -32,6 +32,16 @@
</style>
<![endif]-->
+ <link href='http://activemq.apache.org/styles/highlighter/styles/shCore.css' rel='stylesheet' type='text/css' />
+ <link href='http://activemq.apache.org/styles/highlighter/styles/shThemeEclipse.css' rel='stylesheet' type='text/css' />
+ <script src='http://activemq.apache.org/styles/highlighter/scripts/shCore.js' type='text/javascript'></script>
+ <script src='http://activemq.apache.org/styles/highlighter/scripts/shBrushJava.js' type='text/javascript'></script>
+
+ <script type="text/javascript">
+ SyntaxHighlighter.defaults['toolbar'] = false;
+ SyntaxHighlighter.all();
+ </script>
+
<title>
Apache ActiveMQ ™ -- How should I implement request response with JMS
</title>
@@ -50,8 +60,8 @@
<div>
<!-- Banner -->
-
- <div id="asf_logo">
+<p>
+ </p><div id="asf_logo">
<div id="activemq_logo">
<a shape="rect" style="float:left; width:280px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:10px; margin-left:100px;" href="http://activemq.apache.org" title="The most popular and powerful open source Message Broker">ActiveMQ</a> ™
<a shape="rect" style="float:right; width:210px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:15px; margin-right:10px;" href="http://www.apache.org" title="The Apache Software Foundation">ASF</a>
@@ -99,32 +109,32 @@
<p>So the client side creates a consumer on a temporary queue as follows...</p>
<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
-<pre class="code-java">
-<span class="code-comment">// client side
-</span>Destination tempDest = session.createTemporaryQueue();
+<script class="theme: Default; brush: java; gutter: false" type="syntaxhighlighter"><![CDATA[
+// client side
+Destination tempDest = session.createTemporaryQueue();
MessageConsumer responseConsumer = session.createConsumer(tempDest);
...
-<span class="code-comment">// send a request..
-</span>message.setJMSReplyTo(tempDest)
+// send a request..
+message.setJMSReplyTo(tempDest)
message.setJMSCorrelationID(myCorrelationID);
producer.send(message);
-</pre>
+]]></script>
</div></div>
<h3><a shape="rect" name="HowshouldIimplementrequestresponsewithJMS-Serverside"></a>Server side</h3>
<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
-<pre class="code-java">
-<span class="code-keyword">public</span> void onMessage(Message request) {
+<script class="theme: Default; brush: java; gutter: false" type="syntaxhighlighter"><![CDATA[
+public void onMessage(Message request) {
Message response = session.createMessage();
response.setJMSCorrelationID(request.getJMSCorrelationID())
producer.send(request.getJMSReplyTo(), response)
}
-</pre>
+]]></script>
</div></div>
<h2><a shape="rect" name="HowshouldIimplementrequestresponsewithJMS-FullExamples"></a>Full Examples</h2>
@@ -132,185 +142,185 @@ producer.send(message);
<h3><a shape="rect" name="HowshouldIimplementrequestresponsewithJMS-ServerSide"></a>Server Side</h3>
<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
-<pre class="code-java">
-<span class="code-keyword">import</span> org.apache.activemq.broker.BrokerService;
-<span class="code-keyword">import</span> org.apache.activemq.ActiveMQConnectionFactory;
-
-<span class="code-keyword">import</span> javax.jms.*;
-
-<span class="code-keyword">public</span> class Server <span class="code-keyword">implements</span> MessageListener {
- <span class="code-keyword">private</span> <span class="code-keyword">static</span> <span class="code-object">int</span> ackMode;
- <span class="code-keyword">private</span> <span class="code-keyword">static</span> <span class="code-object">String</span> messageQueueName;
- <span class="code-keyword">private</span> <span class="code-keyword">static</span> <span class="code-object">String</span> messageBrokerUrl;
-
- <span class="code-keyword">private</span> Session session;
- <span class="code-keyword">private</span> <span class="code-object">boolean</span> transacted = <span class="code-keyword">false</span>;
- <span class="code-keyword">private</span> MessageProducer replyProducer;
- <span class="code-keyword">private</span> MessageProtocol messageProtocol;
-
- <span class="code-keyword">static</span> {
- messageBrokerUrl = <span class="code-quote">"tcp:<span class="code-comment">//localhost:61616"</span>;
-</span> messageQueueName = <span class="code-quote">"client.messages"</span>;
+<script class="theme: Default; brush: java; gutter: false" type="syntaxhighlighter"><![CDATA[
+import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.ActiveMQConnectionFactory;
+
+import javax.jms.*;
+
+public class Server implements MessageListener {
+ private static int ackMode;
+ private static String messageQueueName;
+ private static String messageBrokerUrl;
+
+ private Session session;
+ private boolean transacted = false;
+ private MessageProducer replyProducer;
+ private MessageProtocol messageProtocol;
+
+ static {
+ messageBrokerUrl = "tcp://localhost:61616";
+ messageQueueName = "client.messages";
ackMode = Session.AUTO_ACKNOWLEDGE;
}
- <span class="code-keyword">public</span> Server() {
- <span class="code-keyword">try</span> {
- <span class="code-comment">//This message broker is embedded
-</span> BrokerService broker = <span class="code-keyword">new</span> BrokerService();
- broker.setPersistent(<span class="code-keyword">false</span>);
- broker.setUseJmx(<span class="code-keyword">false</span>);
+ public Server() {
+ try {
+ //This message broker is embedded
+ BrokerService broker = new BrokerService();
+ broker.setPersistent(false);
+ broker.setUseJmx(false);
broker.addConnector(messageBrokerUrl);
broker.start();
- } <span class="code-keyword">catch</span> (Exception e) {
- <span class="code-comment">//Handle the exception appropriately
-</span> }
-
- <span class="code-comment">//Delegating the handling of messages to another class, instantiate it before setting up JMS so it
-</span> <span class="code-comment">//is ready to handle messages
-</span> <span class="code-keyword">this</span>.messageProtocol = <span class="code-keyword">new</span> MessageProtocol();
- <span class="code-keyword">this</span>.setupMessageQueueConsumer();
+ } catch (Exception e) {
+ //Handle the exception appropriately
+ }
+
+ //Delegating the handling of messages to another class, instantiate it before setting up JMS so it
+ //is ready to handle messages
+ this.messageProtocol = new MessageProtocol();
+ this.setupMessageQueueConsumer();
}
- <span class="code-keyword">private</span> void setupMessageQueueConsumer() {
- ActiveMQConnectionFactory connectionFactory = <span class="code-keyword">new</span> ActiveMQConnectionFactory(messageBrokerUrl);
+ private void setupMessageQueueConsumer() {
+ ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(messageBrokerUrl);
Connection connection;
- <span class="code-keyword">try</span> {
+ try {
connection = connectionFactory.createConnection();
connection.start();
- <span class="code-keyword">this</span>.session = connection.createSession(<span class="code-keyword">this</span>.transacted, ackMode);
- Destination adminQueue = <span class="code-keyword">this</span>.session.createQueue(messageQueueName);
+ this.session = connection.createSession(this.transacted, ackMode);
+ Destination adminQueue = this.session.createQueue(messageQueueName);
+
+ //Setup a message producer to respond to messages from clients, we will get the destination
+ //to send to from the JMSReplyTo header field from a Message
+ this.replyProducer = this.session.createProducer(null);
+ this.replyProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
+
+ //Set up a consumer to consume messages off of the admin queue
+ MessageConsumer consumer = this.session.createConsumer(adminQueue);
+ consumer.setMessageListener(this);
+ } catch (JMSException e) {
+ //Handle the exception appropriately
+ }
+ }
- <span class="code-comment">//Setup a message producer to respond to messages from clients, we will get the destination
-</span> <span class="code-comment">//to send to from the JMSReplyTo header field from a Message
-</span> <span class="code-keyword">this</span>.replyProducer = <span class="code-keyword">this</span>.session.createProducer(<span class="code-keyword">null</span>);
- <span class="code-keyword">this</span>.replyProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
-
- <span class="code-comment">//Set up a consumer to consume messages off of the admin queue
-</span> MessageConsumer consumer = <span class="code-keyword">this</span>.session.createConsumer(adminQueue);
- consumer.setMessageListener(<span class="code-keyword">this</span>);
- } <span class="code-keyword">catch</span> (JMSException e) {
- <span class="code-comment">//Handle the exception appropriately
-</span> }
- }
-
- <span class="code-keyword">public</span> void onMessage(Message message) {
- <span class="code-keyword">try</span> {
- TextMessage response = <span class="code-keyword">this</span>.session.createTextMessage();
- <span class="code-keyword">if</span> (message <span class="code-keyword">instanceof</span> TextMessage) {
+ public void onMessage(Message message) {
+ try {
+ TextMessage response = this.session.createTextMessage();
+ if (message instanceof TextMessage) {
TextMessage txtMsg = (TextMessage) message;
- <span class="code-object">String</span> messageText = txtMsg.getText();
- response.setText(<span class="code-keyword">this</span>.messageProtocol.handleProtocolMessage(messageText));
+ String messageText = txtMsg.getText();
+ response.setText(this.messageProtocol.handleProtocolMessage(messageText));
}
- <span class="code-comment">//Set the correlation ID from the received message to be the correlation id of the response message
-</span> <span class="code-comment">//<span class="code-keyword">this</span> lets the client identify which message <span class="code-keyword">this</span> is a response to <span class="code-keyword">if</span> it has more than
-</span> <span class="code-comment">//one outstanding message to the server
-</span> response.setJMSCorrelationID(message.getJMSCorrelationID());
-
- <span class="code-comment">//Send the response to the Destination specified by the JMSReplyTo field of the received message,
-</span> <span class="code-comment">//<span class="code-keyword">this</span> is presumably a temporary queue created by the client
-</span> <span class="code-keyword">this</span>.replyProducer.send(message.getJMSReplyTo(), response);
- } <span class="code-keyword">catch</span> (JMSException e) {
- <span class="code-comment">//Handle the exception appropriately
-</span> }
+ //Set the correlation ID from the received message to be the correlation id of the response message
+ //this lets the client identify which message this is a response to if it has more than
+ //one outstanding message to the server
+ response.setJMSCorrelationID(message.getJMSCorrelationID());
+
+ //Send the response to the Destination specified by the JMSReplyTo field of the received message,
+ //this is presumably a temporary queue created by the client
+ this.replyProducer.send(message.getJMSReplyTo(), response);
+ } catch (JMSException e) {
+ //Handle the exception appropriately
+ }
}
- <span class="code-keyword">public</span> <span class="code-keyword">static</span> void main(<span class="code-object">String</span>[] args) {
- <span class="code-keyword">new</span> Server();
+ public static void main(String[] args) {
+ new Server();
}
}
-</pre>
+]]></script>
</div></div>
<h3><a shape="rect" name="HowshouldIimplementrequestresponsewithJMS-ClientSide"></a>Client Side</h3>
<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
-<pre class="code-java">
-<span class="code-keyword">import</span> org.apache.activemq.ActiveMQConnectionFactory;
+<script class="theme: Default; brush: java; gutter: false" type="syntaxhighlighter"><![CDATA[
+import org.apache.activemq.ActiveMQConnectionFactory;
-<span class="code-keyword">import</span> javax.jms.*;
-<span class="code-keyword">import</span> java.util.Random;
+import javax.jms.*;
+import java.util.Random;
-<span class="code-keyword">public</span> class Client <span class="code-keyword">implements</span> MessageListener {
- <span class="code-keyword">private</span> <span class="code-keyword">static</span> <span class="code-object">int</span> ackMode;
- <span class="code-keyword">private</span> <span class="code-keyword">static</span> <span class="code-object">String</span> clientQueueName;
+public class Client implements MessageListener {
+ private static int ackMode;
+ private static String clientQueueName;
- <span class="code-keyword">private</span> <span class="code-object">boolean</span> transacted = <span class="code-keyword">false</span>;
- <span class="code-keyword">private</span> MessageProducer producer;
+ private boolean transacted = false;
+ private MessageProducer producer;
- <span class="code-keyword">static</span> {
- clientQueueName = <span class="code-quote">"client.messages"</span>;
+ static {
+ clientQueueName = "client.messages";
ackMode = Session.AUTO_ACKNOWLEDGE;
}
- <span class="code-keyword">public</span> Client() {
- ActiveMQConnectionFactory connectionFactory = <span class="code-keyword">new</span> ActiveMQConnectionFactory(<span class="code-quote">"tcp:<span class="code-comment">//localhost:61616"</span>);
-</span> Connection connection;
- <span class="code-keyword">try</span> {
+ public Client() {
+ ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
+ Connection connection;
+ try {
connection = connectionFactory.createConnection();
connection.start();
Session session = connection.createSession(transacted, ackMode);
Destination adminQueue = session.createQueue(clientQueueName);
- <span class="code-comment">//Setup a message producer to send message to the queue the server is consuming from
-</span> <span class="code-keyword">this</span>.producer = session.createProducer(adminQueue);
- <span class="code-keyword">this</span>.producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
-
- <span class="code-comment">//Create a temporary queue that <span class="code-keyword">this</span> client will listen <span class="code-keyword">for</span> responses on then create a consumer
-</span> <span class="code-comment">//that consumes message from <span class="code-keyword">this</span> temporary queue...<span class="code-keyword">for</span> a real application a client should reuse
-</span> <span class="code-comment">//the same temp queue <span class="code-keyword">for</span> each message to the server...one temp queue per client
-</span> Destination tempDest = session.createTemporaryQueue();
+ //Setup a message producer to send message to the queue the server is consuming from
+ this.producer = session.createProducer(adminQueue);
+ this.producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
+
+ //Create a temporary queue that this client will listen for responses on then create a consumer
+ //that consumes message from this temporary queue...for a real application a client should reuse
+ //the same temp queue for each message to the server...one temp queue per client
+ Destination tempDest = session.createTemporaryQueue();
MessageConsumer responseConsumer = session.createConsumer(tempDest);
- <span class="code-comment">//This class will handle the messages to the temp queue as well
-</span> responseConsumer.setMessageListener(<span class="code-keyword">this</span>);
+ //This class will handle the messages to the temp queue as well
+ responseConsumer.setMessageListener(this);
- <span class="code-comment">//Now create the actual message you want to send
-</span> TextMessage txtMessage = session.createTextMessage();
- txtMessage.setText(<span class="code-quote">"MyProtocolMessage"</span>);
-
- <span class="code-comment">//Set the reply to field to the temp queue you created above, <span class="code-keyword">this</span> is the queue the server
-</span> <span class="code-comment">//will respond to
-</span> txtMessage.setJMSReplyTo(tempDest);
-
- <span class="code-comment">//Set a correlation ID so when you get a response you know which sent message the response is <span class="code-keyword">for</span>
-</span> <span class="code-comment">//If there is never more than one outstanding message to the server then the
-</span> <span class="code-comment">//same correlation ID can be used <span class="code-keyword">for</span> all the messages...<span class="code-keyword">if</span> there is more than one outstanding
-</span> <span class="code-comment">//message to the server you would presumably want to associate the correlation ID with <span class="code-keyword">this</span>
-</span> <span class="code-comment">//message somehow...a Map works good
-</span> <span class="code-object">String</span> correlationId = <span class="code-keyword">this</span>.createRandomString();
+ //Now create the actual message you want to send
+ TextMessage txtMessage = session.createTextMessage();
+ txtMessage.setText("MyProtocolMessage");
+
+ //Set the reply to field to the temp queue you created above, this is the queue the server
+ //will respond to
+ txtMessage.setJMSReplyTo(tempDest);
+
+ //Set a correlation ID so when you get a response you know which sent message the response is for
+ //If there is never more than one outstanding message to the server then the
+ //same correlation ID can be used for all the messages...if there is more than one outstanding
+ //message to the server you would presumably want to associate the correlation ID with this
+ //message somehow...a Map works good
+ String correlationId = this.createRandomString();
txtMessage.setJMSCorrelationID(correlationId);
- <span class="code-keyword">this</span>.producer.send(txtMessage);
- } <span class="code-keyword">catch</span> (JMSException e) {
- <span class="code-comment">//Handle the exception appropriately
-</span> }
- }
-
- <span class="code-keyword">private</span> <span class="code-object">String</span> createRandomString() {
- Random random = <span class="code-keyword">new</span> Random(<span class="code-object">System</span>.currentTimeMillis());
- <span class="code-object">long</span> randomLong = random.nextLong();
- <span class="code-keyword">return</span> <span class="code-object">Long</span>.toHexString(randomLong);
- }
-
- <span class="code-keyword">public</span> void onMessage(Message message) {
- <span class="code-object">String</span> messageText = <span class="code-keyword">null</span>;
- <span class="code-keyword">try</span> {
- <span class="code-keyword">if</span> (message <span class="code-keyword">instanceof</span> TextMessage) {
+ this.producer.send(txtMessage);
+ } catch (JMSException e) {
+ //Handle the exception appropriately
+ }
+ }
+
+ private String createRandomString() {
+ Random random = new Random(System.currentTimeMillis());
+ long randomLong = random.nextLong();
+ return Long.toHexString(randomLong);
+ }
+
+ public void onMessage(Message message) {
+ String messageText = null;
+ try {
+ if (message instanceof TextMessage) {
TextMessage textMessage = (TextMessage) message;
messageText = textMessage.getText();
- <span class="code-object">System</span>.out.println(<span class="code-quote">"messageText = "</span> + messageText);
+ System.out.println("messageText = " + messageText);
}
- } <span class="code-keyword">catch</span> (JMSException e) {
- <span class="code-comment">//Handle the exception appropriately
-</span> }
+ } catch (JMSException e) {
+ //Handle the exception appropriately
+ }
}
- <span class="code-keyword">public</span> <span class="code-keyword">static</span> void main(<span class="code-object">String</span>[] args) {
- <span class="code-keyword">new</span> Client();
+ public static void main(String[] args) {
+ new Client();
}
}
-</pre>
+]]></script>
</div></div>
<h3><a shape="rect" name="HowshouldIimplementrequestresponsewithJMS-ProtocolClass"></a>Protocol Class</h3>
@@ -318,20 +328,20 @@ producer.send(message);
<p>This class is needed to run the client/server example above. Delegating the handling of messages to a seperate class is solely a personal preference.</p>
<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
-<pre class="code-java">
-<span class="code-keyword">public</span> class MessageProtocol {
- <span class="code-keyword">public</span> <span class="code-object">String</span> handleProtocolMessage(<span class="code-object">String</span> messageText) {
- <span class="code-object">String</span> responseText;
- <span class="code-keyword">if</span> (<span class="code-quote">"MyProtocolMessage"</span>.equalsIgnoreCase(messageText)) {
- responseText = <span class="code-quote">"I recognize your protocol message"</span>;
- } <span class="code-keyword">else</span> {
- responseText = <span class="code-quote">"Unknown protocol message: "</span> + messageText;
+<script class="theme: Default; brush: java; gutter: false" type="syntaxhighlighter"><![CDATA[
+public class MessageProtocol {
+ public String handleProtocolMessage(String messageText) {
+ String responseText;
+ if ("MyProtocolMessage".equalsIgnoreCase(messageText)) {
+ responseText = "I recognize your protocol message";
+ } else {
+ responseText = "Unknown protocol message: " + messageText;
}
- <span class="code-keyword">return</span> responseText;
+ return responseText;
}
}
-</pre>
+]]></script>
</div></div>
</div>
</td>
@@ -346,8 +356,8 @@ producer.send(message);
<h3><a shape="rect" name="Navigation-Search"></a>Search</h3>
-
-<div>
+<p>
+</p><div>
<form enctype="application/x-www-form-urlencoded" method="get" action="http://www.google.com/search" style="font-size: 10px;">
<input type="hidden" name="ie" value="UTF-8">
<input type="hidden" name="oe" value="UTF-8">
Modified: websites/production/activemq/content/how-should-i-package-applications-using-camel-and-activemq.html
==============================================================================
--- websites/production/activemq/content/how-should-i-package-applications-using-camel-and-activemq.html (original)
+++ websites/production/activemq/content/how-should-i-package-applications-using-camel-and-activemq.html Fri Jul 12 12:46:14 2013
@@ -32,6 +32,7 @@
</style>
<![endif]-->
+
<title>
Apache ActiveMQ ™ -- How should I package applications using Camel and ActiveMQ
</title>
@@ -50,8 +51,8 @@
<div>
<!-- Banner -->
-
- <div id="asf_logo">
+<p>
+ </p><div id="asf_logo">
<div id="activemq_logo">
<a shape="rect" style="float:left; width:280px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:10px; margin-left:100px;" href="http://activemq.apache.org" title="The most popular and powerful open source Message Broker">ActiveMQ</a> ™
<a shape="rect" style="float:right; width:210px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:15px; margin-right:10px;" href="http://www.apache.org" title="The Apache Software Foundation">ASF</a>
@@ -97,8 +98,8 @@
<h3><a shape="rect" name="Navigation-Search"></a>Search</h3>
-
-<div>
+<p>
+</p><div>
<form enctype="application/x-www-form-urlencoded" method="get" action="http://www.google.com/search" style="font-size: 10px;">
<input type="hidden" name="ie" value="UTF-8">
<input type="hidden" name="oe" value="UTF-8">
Modified: websites/production/activemq/content/how-should-i-use-the-vm-transport.html
==============================================================================
--- websites/production/activemq/content/how-should-i-use-the-vm-transport.html (original)
+++ websites/production/activemq/content/how-should-i-use-the-vm-transport.html Fri Jul 12 12:46:14 2013
@@ -32,6 +32,16 @@
</style>
<![endif]-->
+ <link href='http://activemq.apache.org/styles/highlighter/styles/shCore.css' rel='stylesheet' type='text/css' />
+ <link href='http://activemq.apache.org/styles/highlighter/styles/shThemeEclipse.css' rel='stylesheet' type='text/css' />
+ <script src='http://activemq.apache.org/styles/highlighter/scripts/shCore.js' type='text/javascript'></script>
+ <script src='http://activemq.apache.org/styles/highlighter/scripts/shBrushJava.js' type='text/javascript'></script>
+
+ <script type="text/javascript">
+ SyntaxHighlighter.defaults['toolbar'] = false;
+ SyntaxHighlighter.all();
+ </script>
+
<title>
Apache ActiveMQ ™ -- How should I use the VM transport
</title>
@@ -50,8 +60,8 @@
<div>
<!-- Banner -->
-
- <div id="asf_logo">
+<p>
+ </p><div id="asf_logo">
<div id="activemq_logo">
<a shape="rect" style="float:left; width:280px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:10px; margin-left:100px;" href="http://activemq.apache.org" title="The most popular and powerful open source Message Broker">ActiveMQ</a> ™
<a shape="rect" style="float:right; width:210px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:15px; margin-right:10px;" href="http://www.apache.org" title="The Apache Software Foundation">ASF</a>
@@ -93,9 +103,10 @@
<p>You can disable the automatic serialization of ObjectMessage payloads so that the objects are passed by value in 4.x by setting the <b>objectMessageSerializationDefered</b> flag to true on the ActiveMQConnectionFactory (or ActiveMQConnection).</p>
<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
-<pre class="code-java">ActiveMQConnectionFactory factory = <span class="code-keyword">new</span> ActiveMQConnectionFactory(<span class="code-quote">"vm:<span class="code-comment">//localhost"</span>);
-</span>factory.setObjectMessageSerializationDefered(<span class="code-keyword">true</span>);
-</pre>
+<script class="theme: Default; brush: java; gutter: false" type="syntaxhighlighter"><![CDATA[
+ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("vm://localhost");
+factory.setObjectMessageSerializationDefered(true);
+]]></script>
</div></div>
<p> </p>
@@ -117,8 +128,8 @@
<h3><a shape="rect" name="Navigation-Search"></a>Search</h3>
-
-<div>
+<p>
+</p><div>
<form enctype="application/x-www-form-urlencoded" method="get" action="http://www.google.com/search" style="font-size: 10px;">
<input type="hidden" name="ie" value="UTF-8">
<input type="hidden" name="oe" value="UTF-8">
Modified: websites/production/activemq/content/how-to-configure-a-new-database.html
==============================================================================
--- websites/production/activemq/content/how-to-configure-a-new-database.html (original)
+++ websites/production/activemq/content/how-to-configure-a-new-database.html Fri Jul 12 12:46:14 2013
@@ -32,6 +32,16 @@
</style>
<![endif]-->
+ <link href='http://activemq.apache.org/styles/highlighter/styles/shCore.css' rel='stylesheet' type='text/css' />
+ <link href='http://activemq.apache.org/styles/highlighter/styles/shThemeEclipse.css' rel='stylesheet' type='text/css' />
+ <script src='http://activemq.apache.org/styles/highlighter/scripts/shCore.js' type='text/javascript'></script>
+ <script src='http://activemq.apache.org/styles/highlighter/scripts/shBrushJava.js' type='text/javascript'></script>
+
+ <script type="text/javascript">
+ SyntaxHighlighter.defaults['toolbar'] = false;
+ SyntaxHighlighter.all();
+ </script>
+
<title>
Apache ActiveMQ ™ -- How to configure a new database
</title>
@@ -50,8 +60,8 @@
<div>
<!-- Banner -->
-
- <div id="asf_logo">
+<p>
+ </p><div id="asf_logo">
<div id="activemq_logo">
<a shape="rect" style="float:left; width:280px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:10px; margin-left:100px;" href="http://activemq.apache.org" title="The most popular and powerful open source Message Broker">ActiveMQ</a> ™
<a shape="rect" style="float:right; width:210px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:15px; margin-right:10px;" href="http://www.apache.org" title="The Apache Software Foundation">ASF</a>
@@ -80,37 +90,39 @@
<p>e.g.</p>
<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
-<pre class="code-java"> <bean id=<span class="code-quote">"mysql-ds"</span> class=<span class="code-quote">"org.apache.commons.dbcp.BasicDataSource"</span> destroy-method=<span class="code-quote">"close"</span>>
- <property name=<span class="code-quote">"driverClassName"</span> value=<span class="code-quote">"com.mysql.jdbc.Driver"</span>/>
- <property name=<span class="code-quote">"url"</span> value=<span class="code-quote">"jdbc:mysql:<span class="code-comment">//localhost/activemq"</span>/>
-</span> <property name=<span class="code-quote">"username"</span> value=<span class="code-quote">"activemq"</span>/>
- <property name=<span class="code-quote">"password"</span> value=<span class="code-quote">"activemq"</span>/>
- <property name=<span class="code-quote">"poolPreparedStatements"</span> value=<span class="code-quote">"<span class="code-keyword">true</span>"</span>/>
+<script class="theme: Default; brush: java; gutter: false" type="syntaxhighlighter"><![CDATA[
+ <bean id="mysql-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
+ <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
+ <property name="url" value="jdbc:mysql://localhost/activemq"/>
+ <property name="username" value="activemq"/>
+ <property name="password" value="activemq"/>
+ <property name="poolPreparedStatements" value="true"/>
</bean>
-</pre>
+]]></script>
</div></div>
<p><b>For AMQ 3.x</b></p>
<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
-<pre class="code-java"><bean id=<span class="code-quote">"mssql-ds"</span> class=<span class="code-quote">"org.apache.commons.dbcp.BasicDataSource"</span> destroy-method=<span class="code-quote">"close"</span>>
- <property name=<span class="code-quote">"driverClassName"</span>>
+<script class="theme: Default; brush: java; gutter: false" type="syntaxhighlighter"><![CDATA[
+<bean id="mssql-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
+ <property name="driverClassName">
<value>com.microsoft.jdbc.sqlserver.SQLServerDriver</value>
</property>
- <property name=<span class="code-quote">"url"</span>>
- <value>jdbc:microsoft:sqlserver:<span class="code-comment">//localhost:1433;DatabaseName=activedb</value>
-</span> </property>
- <property name=<span class="code-quote">"username"</span>>
+ <property name="url">
+ <value>jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=activedb</value>
+ </property>
+ <property name="username">
<value>sa</value>
</property>
- <property name=<span class="code-quote">"password"</span>>
+ <property name="password">
<value></value>
</property>
- <property name=<span class="code-quote">"poolPreparedStatements"</span>>
- <value><span class="code-keyword">true</span></value>
+ <property name="poolPreparedStatements">
+ <value>true</value>
</property>
</bean>
-</pre>
+]]></script>
</div></div>
<p>2. Set the datasource reference to use the new jdbc configuration e.g <jdbcPersistence dataSourceRef="mssql-ds"/></p>
@@ -128,8 +140,8 @@
<h3><a shape="rect" name="Navigation-Search"></a>Search</h3>
-
-<div>
+<p>
+</p><div>
<form enctype="application/x-www-form-urlencoded" method="get" action="http://www.google.com/search" style="font-size: 10px;">
<input type="hidden" name="ie" value="UTF-8">
<input type="hidden" name="oe" value="UTF-8">
Modified: websites/production/activemq/content/how-to-deal-with-large-number-of-threads-in-clients.html
==============================================================================
--- websites/production/activemq/content/how-to-deal-with-large-number-of-threads-in-clients.html (original)
+++ websites/production/activemq/content/how-to-deal-with-large-number-of-threads-in-clients.html Fri Jul 12 12:46:14 2013
@@ -32,6 +32,16 @@
</style>
<![endif]-->
+ <link href='http://activemq.apache.org/styles/highlighter/styles/shCore.css' rel='stylesheet' type='text/css' />
+ <link href='http://activemq.apache.org/styles/highlighter/styles/shThemeEclipse.css' rel='stylesheet' type='text/css' />
+ <script src='http://activemq.apache.org/styles/highlighter/scripts/shCore.js' type='text/javascript'></script>
+ <script src='http://activemq.apache.org/styles/highlighter/scripts/shBrushJava.js' type='text/javascript'></script>
+
+ <script type="text/javascript">
+ SyntaxHighlighter.defaults['toolbar'] = false;
+ SyntaxHighlighter.all();
+ </script>
+
<title>
Apache ActiveMQ ™ -- How to deal with large number of threads in clients
</title>
@@ -50,8 +60,8 @@
<div>
<!-- Banner -->
-
- <div id="asf_logo">
+<p>
+ </p><div id="asf_logo">
<div id="activemq_logo">
<a shape="rect" style="float:left; width:280px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:10px; margin-left:100px;" href="http://activemq.apache.org" title="The most popular and powerful open source Message Broker">ActiveMQ</a> ™
<a shape="rect" style="float:right; width:210px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:15px; margin-right:10px;" href="http://www.apache.org" title="The Apache Software Foundation">ASF</a>
@@ -77,19 +87,19 @@
<p>In 5.7 we bounded this executor to a maximum of 1000 threads by default, which we believe should be enough for most use cases. In case of large number of busy sessions, each of them could end up using large number of threads and eventually OOM your application. There are couple of things you can do. The first obvious thing is to decrease the max thread limit a session can use, like this:</p>
<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
-<pre class="code-java">ActiveMQConnectionFactory connectionFactory = <span class="code-keyword">new</span> ActiveMQConnectionFactory(<span class="code-quote">"tcp:<span class="code-comment">//localhost:61616"</span>);
-</span>connectionFactory.setMaxThreadPoolSize(10);
+<script class="theme: Default; brush: java; gutter: false" type="syntaxhighlighter"><![CDATA[ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
+connectionFactory.setMaxThreadPoolSize(10);
Connection conn = connectionFactory.createConnection();
-conn.start();</pre>
+conn.start();]]></script>
</div></div>
<p>On the other hand this can lead to the scenario where a single session exaust its max thread number. A default behavior of <tt>ThreadPoolExecutor</tt> in this case is to throw an exception, so you'll notice it. A workaround for this scenario is to provide a rejected task handler that will synchronize the execution with the calling thread, like this</p>
<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
-<pre class="code-java">ActiveMQConnectionFactory connectionFactory = <span class="code-keyword">new</span> ActiveMQConnectionFactory(<span class="code-quote">"tcp:<span class="code-comment">//localhost:61616"</span>);
-</span>connectionFactory.setRejectedTaskHandler(<span class="code-keyword">new</span> ThreadPoolExecutor.CallerRunsPolicy());
+<script class="theme: Default; brush: java; gutter: false" type="syntaxhighlighter"><![CDATA[ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
+connectionFactory.setRejectedTaskHandler(new ThreadPoolExecutor.CallerRunsPolicy());
Connection conn = connectionFactory.createConnection();
-conn.start();</pre>
+conn.start();]]></script>
</div></div>
<p>This will prevent the <tt>ThreadPoolExecutor</tt> from throwing an exception when it reaches its bound. Instead it will execute the rejected task in the calling thread.</p>
@@ -97,10 +107,10 @@ conn.start();</pre>
<p>Finally, you can eliminate these threads completly, you can do that by setting <tt>alwaysSessionAsync</tt> property to false</p>
<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
-<pre class="code-java">ActiveMQConnectionFactory connectionFactory = <span class="code-keyword">new</span> ActiveMQConnectionFactory(<span class="code-quote">"tcp:<span class="code-comment">//localhost:61616"</span>);
-</span>connectionFactory.setAlwaysSessionAsync(<span class="code-keyword">false</span>);
+<script class="theme: Default; brush: java; gutter: false" type="syntaxhighlighter"><![CDATA[ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
+connectionFactory.setAlwaysSessionAsync(false);
Connection conn = connectionFactory.createConnection();
-conn.start();</pre>
+conn.start();]]></script>
</div></div>
<p>However you need to have in mind that this approach can affect performance of the whole system.</p>
@@ -119,8 +129,8 @@ conn.start();</pre>
<h3><a shape="rect" name="Navigation-Search"></a>Search</h3>
-
-<div>
+<p>
+</p><div>
<form enctype="application/x-www-form-urlencoded" method="get" action="http://www.google.com/search" style="font-size: 10px;">
<input type="hidden" name="ie" value="UTF-8">
<input type="hidden" name="oe" value="UTF-8">
Modified: websites/production/activemq/content/how-to-deploy-activemq-ra-versionrar-to-weblogic.html
==============================================================================
--- websites/production/activemq/content/how-to-deploy-activemq-ra-versionrar-to-weblogic.html (original)
+++ websites/production/activemq/content/how-to-deploy-activemq-ra-versionrar-to-weblogic.html Fri Jul 12 12:46:14 2013
@@ -32,6 +32,17 @@
</style>
<![endif]-->
+ <link href='http://activemq.apache.org/styles/highlighter/styles/shCore.css' rel='stylesheet' type='text/css' />
+ <link href='http://activemq.apache.org/styles/highlighter/styles/shThemeEclipse.css' rel='stylesheet' type='text/css' />
+ <script src='http://activemq.apache.org/styles/highlighter/scripts/shCore.js' type='text/javascript'></script>
+ <script src='http://activemq.apache.org/styles/highlighter/scripts/shBrushJava.js' type='text/javascript'></script>
+ <script src='http://activemq.apache.org/styles/highlighter/scripts/shBrushXml.js' type='text/javascript'></script>
+
+ <script type="text/javascript">
+ SyntaxHighlighter.defaults['toolbar'] = false;
+ SyntaxHighlighter.all();
+ </script>
+
<title>
Apache ActiveMQ ™ -- How to deploy activemq-ra-version.rar to weblogic
</title>
@@ -50,8 +61,8 @@
<div>
<!-- Banner -->
-
- <div id="asf_logo">
+<p>
+ </p><div id="asf_logo">
<div id="activemq_logo">
<a shape="rect" style="float:left; width:280px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:10px; margin-left:100px;" href="http://activemq.apache.org" title="The most popular and powerful open source Message Broker">ActiveMQ</a> ™
<a shape="rect" style="float:right; width:210px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:15px; margin-right:10px;" href="http://www.apache.org" title="The Apache Software Foundation">ASF</a>
@@ -80,8 +91,9 @@
<ol><li>Add the BrokerXmlConfig file called "broker-config.xml" in the classpath. This can be found in the rar file "activemq-rar-*.rar". Otherwise, modify ra.xml by providing an absolute path to "broker-config.xml", see below.
<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
-<pre class="code-xml"><span class="code-tag"><config-property></span>
- <span class="code-tag"><description></span>
+<script class="theme: Default; brush: xml; gutter: false" type="syntaxhighlighter"><![CDATA[
+<config-property>
+ <description>
Sets the XML configuration file used to configure the ActiveMQ broker via
Spring if using embedded mode.
@@ -89,12 +101,12 @@
a URL is specified. So a value of foo/bar.xml would be assumed to be on the
classpath whereas file:dir/file.xml would use the file system.
Any valid URL string is supported.
- <span class="code-tag"></description></span>
- <span class="code-tag"><config-property-name></span>BrokerXmlConfig<span class="code-tag"></config-property-name></span>
- <span class="code-tag"><config-property-type></span>java.lang.String<span class="code-tag"></config-property-type></span>
- <span class="code-tag"><config-property-value></span>xbean:file:C:\broker-config.xml<span class="code-tag"></config-property-value></span>
-<span class="code-tag"></config-property></span>
-</pre>
+ </description>
+ <config-property-name>BrokerXmlConfig</config-property-name>
+ <config-property-type>java.lang.String</config-property-type>
+ <config-property-value>xbean:file:C:\broker-config.xml</config-property-value>
+</config-property>
+]]></script>
</div></div>
<p> 
<br clear="none" class="atl-forced-newline">
@@ -115,8 +127,8 @@
<h3><a shape="rect" name="Navigation-Search"></a>Search</h3>
-
-<div>
+<p>
+</p><div>
<form enctype="application/x-www-form-urlencoded" method="get" action="http://www.google.com/search" style="font-size: 10px;">
<input type="hidden" name="ie" value="UTF-8">
<input type="hidden" name="oe" value="UTF-8">
Modified: websites/production/activemq/content/how-to-disable-auto-destination-creation.html
==============================================================================
--- websites/production/activemq/content/how-to-disable-auto-destination-creation.html (original)
+++ websites/production/activemq/content/how-to-disable-auto-destination-creation.html Fri Jul 12 12:46:14 2013
@@ -32,6 +32,7 @@
</style>
<![endif]-->
+
<title>
Apache ActiveMQ ™ -- How to disable auto destination creation
</title>
Modified: websites/production/activemq/content/how-to-disable-multicast-discovery.html
==============================================================================
--- websites/production/activemq/content/how-to-disable-multicast-discovery.html (original)
+++ websites/production/activemq/content/how-to-disable-multicast-discovery.html Fri Jul 12 12:46:14 2013
@@ -32,6 +32,16 @@
</style>
<![endif]-->
+ <link href='http://activemq.apache.org/styles/highlighter/styles/shCore.css' rel='stylesheet' type='text/css' />
+ <link href='http://activemq.apache.org/styles/highlighter/styles/shThemeEclipse.css' rel='stylesheet' type='text/css' />
+ <script src='http://activemq.apache.org/styles/highlighter/scripts/shCore.js' type='text/javascript'></script>
+ <script src='http://activemq.apache.org/styles/highlighter/scripts/shBrushJava.js' type='text/javascript'></script>
+
+ <script type="text/javascript">
+ SyntaxHighlighter.defaults['toolbar'] = false;
+ SyntaxHighlighter.all();
+ </script>
+
<title>
Apache ActiveMQ ™ -- How to disable multicast discovery?
</title>
@@ -50,8 +60,8 @@
<div>
<!-- Banner -->
-
- <div id="asf_logo">
+<p>
+ </p><div id="asf_logo">
<div id="activemq_logo">
<a shape="rect" style="float:left; width:280px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:10px; margin-left:100px;" href="http://activemq.apache.org" title="The most popular and powerful open source Message Broker">ActiveMQ</a> ™
<a shape="rect" style="float:right; width:210px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:15px; margin-right:10px;" href="http://www.apache.org" title="The Apache Software Foundation">ASF</a>
@@ -77,25 +87,21 @@ If multicast is not required, the multic
<p>To stop advertising your connection URI on the multicast network remove the discoveryUri attribute from the <transportConnector/>:</p>
-<p>replace:</p>
-<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
-<pre class="code-java">
-<transportConnector name=<span class="code-quote">"openwire"</span> uri=<span class="code-quote">"tcp:<span class="code-comment">//localhost:61616"</span> discoveryUri=<span class="code-quote">"multicast://<span class="code-keyword">default</span>"</span>/></span>
-</pre>
-</div></div>
-<p>with:</p>
-<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
-<pre class="code-java">
-<transportConnector name=<span class="code-quote">"openwire"</span> uri=<span class="code-quote">"tcp:<span class="code-comment">//localhost:61616"</span> /></span>
-</pre>
+<p>replace:</p><div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
+<script class="theme: Default; brush: java; gutter: false" type="syntaxhighlighter"><![CDATA[
+<transportConnector name="openwire" uri="tcp://localhost:61616" discoveryUri="multicast://default"/>
+]]></script>
+</div></div>with:<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
+<script class="theme: Default; brush: java; gutter: false" type="syntaxhighlighter"><![CDATA[
+<transportConnector name="openwire" uri="tcp://localhost:61616" />
+]]></script>
</div></div>
-<p>If you do not require any networked broker support remove the <networkConnector/> altogether. Remove </p>
-<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
-<pre class="code-java"><networkConnector name=<span class="code-quote">"<span class="code-keyword">default</span>-nc"</span> uri=<span class="code-quote">"multicast:<span class="code-comment">//<span class="code-keyword">default</span>"</span>/></span>
-</pre>
-</div></div>
-<p>Alternatively, provide a static networkConnector for each broker you wish to network with by replacing the the discoveryUri with the static transport connection URI of your target broker.</p>
+<p>If you do not require any networked broker support remove the <networkConnector/> altogether. Remove </p><div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
+<script class="theme: Default; brush: java; gutter: false" type="syntaxhighlighter"><![CDATA[<networkConnector name="default-nc" uri="multicast://default"/>
+]]></script>
+</div></div><br clear="none">
+Alternatively, provide a static networkConnector for each broker you wish to network with by replacing the the discoveryUri with the static transport connection URI of your target broker.
<p>For more information see the <a shape="rect" href="discovery-transport-reference.html" title="Discovery Transport Reference">Discovery Transport Reference</a></p>
</div>
@@ -111,8 +117,8 @@ If multicast is not required, the multic
<h3><a shape="rect" name="Navigation-Search"></a>Search</h3>
-
-<div>
+<p>
+</p><div>
<form enctype="application/x-www-form-urlencoded" method="get" action="http://www.google.com/search" style="font-size: 10px;">
<input type="hidden" name="ie" value="UTF-8">
<input type="hidden" name="oe" value="UTF-8">
Modified: websites/production/activemq/content/how-to-unit-test-jms-code.html
==============================================================================
--- websites/production/activemq/content/how-to-unit-test-jms-code.html (original)
+++ websites/production/activemq/content/how-to-unit-test-jms-code.html Fri Jul 12 12:46:14 2013
@@ -32,6 +32,16 @@
</style>
<![endif]-->
+ <link href='http://activemq.apache.org/styles/highlighter/styles/shCore.css' rel='stylesheet' type='text/css' />
+ <link href='http://activemq.apache.org/styles/highlighter/styles/shThemeEclipse.css' rel='stylesheet' type='text/css' />
+ <script src='http://activemq.apache.org/styles/highlighter/scripts/shCore.js' type='text/javascript'></script>
+ <script src='http://activemq.apache.org/styles/highlighter/scripts/shBrushJava.js' type='text/javascript'></script>
+
+ <script type="text/javascript">
+ SyntaxHighlighter.defaults['toolbar'] = false;
+ SyntaxHighlighter.all();
+ </script>
+
<title>
Apache ActiveMQ ™ -- How to unit test JMS code
</title>
@@ -50,8 +60,8 @@
<div>
<!-- Banner -->
-
- <div id="asf_logo">
+<p>
+ </p><div id="asf_logo">
<div id="activemq_logo">
<a shape="rect" style="float:left; width:280px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:10px; margin-left:100px;" href="http://activemq.apache.org" title="The most popular and powerful open source Message Broker">ActiveMQ</a> ™
<a shape="rect" style="float:right; width:210px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:15px; margin-right:10px;" href="http://www.apache.org" title="The Apache Software Foundation">ASF</a>
@@ -82,9 +92,9 @@
<p>You can do all of this using the following Java code to create your JMS ConnectionFactory which will also automatically create an embedded broker</p>
<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
-<pre class="code-java">
-ConnectionFactory connectionFactory = <span class="code-keyword">new</span> ActiveMQConnectionFactory(<span class="code-quote">"vm:<span class="code-comment">//localhost?broker.persistent=<span class="code-keyword">false</span>"</span>);</span>
-</pre>
+<script class="theme: Default; brush: java; gutter: false" type="syntaxhighlighter"><![CDATA[
+ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("vm://localhost?broker.persistent=false");
+]]></script>
</div></div>
<p>For more configuration options see the <a shape="rect" href="vm-transport-reference.html" title="VM Transport Reference">VM Transport Reference</a> and the <a shape="rect" href="broker-configuration-uri.html" title="Broker Configuration URI">Broker Configuration URI</a></p>
@@ -92,11 +102,11 @@ ConnectionFactory connectionFactory = <s
<p>Or if you really would rather be more explicit you can create the broker first using the following Java code </p>
<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
-<pre class="code-java">
-BrokerService broker = <span class="code-keyword">new</span> BrokerService();
-broker.setPersistent(<span class="code-keyword">false</span>);
+<script class="theme: Default; brush: java; gutter: false" type="syntaxhighlighter"><![CDATA[
+BrokerService broker = new BrokerService();
+broker.setPersistent(false);
broker.start();
-</pre>
+]]></script>
</div></div>
<p>or you could use the <a shape="rect" href="spring-support.html" title="Spring Support">Spring Support</a></p>
@@ -108,18 +118,18 @@ broker.start();
<p>Add the following jndi.properties to your classpath (e.g. in src/test/resources if you are using maven).</p>
<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
-<pre class="code-java">
+<script class="theme: Default; brush: java; gutter: false" type="syntaxhighlighter"><![CDATA[
java.naming.factory.initial = org.apache.activemq.jndi.ActiveMQInitialContextFactory
-java.naming.provider.url = vm:<span class="code-comment">//localhost?broker.persistent=<span class="code-keyword">false</span></span>
-</pre>
+java.naming.provider.url = vm://localhost?broker.persistent=false
+]]></script>
</div></div>
<p>You should then consider using <a shape="rect" href="jndi-support.html" title="JNDI Support">Dynamic destinations in JNDI</a> so that your code looks up destinations via</p>
<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
-<pre class="code-java">
-context.lookup(<span class="code-quote">"dynamicQueues/FOO.BAR"</span>);
-</pre>
+<script class="theme: Default; brush: java; gutter: false" type="syntaxhighlighter"><![CDATA[
+context.lookup("dynamicQueues/FOO.BAR");
+]]></script>
</div></div>
<p>To avoid having to explicitly configure every single JMS destination in the jndi.properties file, please see the <a shape="rect" href="how-do-i-create-new-destinations.html" title="How do I create new destinations">other options for creating destinations</a>.</p>
@@ -137,8 +147,8 @@ context.lookup(<span class="code-quote">
<h3><a shape="rect" name="Navigation-Search"></a>Search</h3>
-
-<div>
+<p>
+</p><div>
<form enctype="application/x-www-form-urlencoded" method="get" action="http://www.google.com/search" style="font-size: 10px;">
<input type="hidden" name="ie" value="UTF-8">
<input type="hidden" name="oe" value="UTF-8">
Modified: websites/production/activemq/content/how-you-can-help-release.html
==============================================================================
--- websites/production/activemq/content/how-you-can-help-release.html (original)
+++ websites/production/activemq/content/how-you-can-help-release.html Fri Jul 12 12:46:14 2013
@@ -32,6 +32,7 @@
</style>
<![endif]-->
+
<title>
Apache ActiveMQ ™ -- How you can help release
</title>
@@ -50,8 +51,8 @@
<div>
<!-- Banner -->
-
- <div id="asf_logo">
+<p>
+ </p><div id="asf_logo">
<div id="activemq_logo">
<a shape="rect" style="float:left; width:280px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:10px; margin-left:100px;" href="http://activemq.apache.org" title="The most popular and powerful open source Message Broker">ActiveMQ</a> ™
<a shape="rect" style="float:right; width:210px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:15px; margin-right:10px;" href="http://www.apache.org" title="The Apache Software Foundation">ASF</a>
@@ -90,8 +91,8 @@
<h3><a shape="rect" name="Navigation-Search"></a>Search</h3>
-
-<div>
+<p>
+</p><div>
<form enctype="application/x-www-form-urlencoded" method="get" action="http://www.google.com/search" style="font-size: 10px;">
<input type="hidden" name="ie" value="UTF-8">
<input type="hidden" name="oe" value="UTF-8">
Modified: websites/production/activemq/content/http-and-https-transports-reference.html
==============================================================================
--- websites/production/activemq/content/http-and-https-transports-reference.html (original)
+++ websites/production/activemq/content/http-and-https-transports-reference.html Fri Jul 12 12:46:14 2013
@@ -32,6 +32,7 @@
</style>
<![endif]-->
+
<title>
Apache ActiveMQ ™ -- HTTP and HTTPs Transports Reference
</title>
@@ -50,8 +51,8 @@
<div>
<!-- Banner -->
-
- <div id="asf_logo">
+<p>
+ </p><div id="asf_logo">
<div id="activemq_logo">
<a shape="rect" style="float:left; width:280px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:10px; margin-left:100px;" href="http://activemq.apache.org" title="The most popular and powerful open source Message Broker">ActiveMQ</a> ™
<a shape="rect" style="float:right; width:210px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:15px; margin-right:10px;" href="http://www.apache.org" title="The Apache Software Foundation">ASF</a>
@@ -117,8 +118,8 @@ https://localhost:8080
<h3><a shape="rect" name="Navigation-Search"></a>Search</h3>
-
-<div>
+<p>
+</p><div>
<form enctype="application/x-www-form-urlencoded" method="get" action="http://www.google.com/search" style="font-size: 10px;">
<input type="hidden" name="ie" value="UTF-8">
<input type="hidden" name="oe" value="UTF-8">
Modified: websites/production/activemq/content/i-am-having-problems-with-the-spring-jmstemplate.html
==============================================================================
--- websites/production/activemq/content/i-am-having-problems-with-the-spring-jmstemplate.html (original)
+++ websites/production/activemq/content/i-am-having-problems-with-the-spring-jmstemplate.html Fri Jul 12 12:46:14 2013
@@ -32,6 +32,7 @@
</style>
<![endif]-->
+
<title>
Apache ActiveMQ ™ -- I am having problems with the Spring JmsTemplate
</title>
@@ -50,8 +51,8 @@
<div>
<!-- Banner -->
-
- <div id="asf_logo">
+<p>
+ </p><div id="asf_logo">
<div id="activemq_logo">
<a shape="rect" style="float:left; width:280px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:10px; margin-left:100px;" href="http://activemq.apache.org" title="The most popular and powerful open source Message Broker">ActiveMQ</a> ™
<a shape="rect" style="float:right; width:210px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:15px; margin-right:10px;" href="http://www.apache.org" title="The Apache Software Foundation">ASF</a>
@@ -88,8 +89,8 @@
<h3><a shape="rect" name="Navigation-Search"></a>Search</h3>
-
-<div>
+<p>
+</p><div>
<form enctype="application/x-www-form-urlencoded" method="get" action="http://www.google.com/search" style="font-size: 10px;">
<input type="hidden" name="ie" value="UTF-8">
<input type="hidden" name="oe" value="UTF-8">
Modified: websites/production/activemq/content/i-am-not-receiving-any-messages-what-is-wrong.html
==============================================================================
--- websites/production/activemq/content/i-am-not-receiving-any-messages-what-is-wrong.html (original)
+++ websites/production/activemq/content/i-am-not-receiving-any-messages-what-is-wrong.html Fri Jul 12 12:46:14 2013
@@ -32,6 +32,7 @@
</style>
<![endif]-->
+
<title>
Apache ActiveMQ ™ -- I am not receiving any messages, what is wrong
</title>
@@ -50,8 +51,8 @@
<div>
<!-- Banner -->
-
- <div id="asf_logo">
+<p>
+ </p><div id="asf_logo">
<div id="activemq_logo">
<a shape="rect" style="float:left; width:280px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:10px; margin-left:100px;" href="http://activemq.apache.org" title="The most popular and powerful open source Message Broker">ActiveMQ</a> ™
<a shape="rect" style="float:right; width:210px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:15px; margin-right:10px;" href="http://www.apache.org" title="The Apache Software Foundation">ASF</a>
@@ -99,8 +100,8 @@
<h3><a shape="rect" name="Navigation-Search"></a>Search</h3>
-
-<div>
+<p>
+</p><div>
<form enctype="application/x-www-form-urlencoded" method="get" action="http://www.google.com/search" style="font-size: 10px;">
<input type="hidden" name="ie" value="UTF-8">
<input type="hidden" name="oe" value="UTF-8">
Modified: websites/production/activemq/content/i-cannot-connect-to-activemq-from-jconsole.html
==============================================================================
--- websites/production/activemq/content/i-cannot-connect-to-activemq-from-jconsole.html (original)
+++ websites/production/activemq/content/i-cannot-connect-to-activemq-from-jconsole.html Fri Jul 12 12:46:14 2013
@@ -32,6 +32,16 @@
</style>
<![endif]-->
+ <link href='http://activemq.apache.org/styles/highlighter/styles/shCore.css' rel='stylesheet' type='text/css' />
+ <link href='http://activemq.apache.org/styles/highlighter/styles/shThemeEclipse.css' rel='stylesheet' type='text/css' />
+ <script src='http://activemq.apache.org/styles/highlighter/scripts/shCore.js' type='text/javascript'></script>
+ <script src='http://activemq.apache.org/styles/highlighter/scripts/shBrushJava.js' type='text/javascript'></script>
+
+ <script type="text/javascript">
+ SyntaxHighlighter.defaults['toolbar'] = false;
+ SyntaxHighlighter.all();
+ </script>
+
<title>
Apache ActiveMQ ™ -- I cannot connect to ActiveMQ from JConsole
</title>
@@ -50,8 +60,8 @@
<div>
<!-- Banner -->
-
- <div id="asf_logo">
+<p>
+ </p><div id="asf_logo">
<div id="activemq_logo">
<a shape="rect" style="float:left; width:280px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:10px; margin-left:100px;" href="http://activemq.apache.org" title="The most popular and powerful open source Message Broker">ActiveMQ</a> ™
<a shape="rect" style="float:right; width:210px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:15px; margin-right:10px;" href="http://www.apache.org" title="The Apache Software Foundation">ASF</a>
@@ -77,17 +87,19 @@
<p>e.g. on unix (OS X, Linux, Solaris)</p>
<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
-<pre class="code-java">export ACTIVEMQ_OPTS=$ACTIVEMQ_OPTS -Djava.rmi.server.hostname=<hostname>
+<script class="theme: Default; brush: java; gutter: false" type="syntaxhighlighter"><![CDATA[
+export ACTIVEMQ_OPTS=$ACTIVEMQ_OPTS -Djava.rmi.server.hostname=<hostname>
activemq
-</pre>
+]]></script>
</div></div>
<p>or on Windows</p>
<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
-<pre class="code-java">SET ACTIVEMQ_OPTS=%ACTIVEMQ_OPTS% -Djava.rmi.server.hostname=<hostname>
+<script class="theme: Default; brush: java; gutter: false" type="syntaxhighlighter"><![CDATA[
+SET ACTIVEMQ_OPTS=%ACTIVEMQ_OPTS% -Djava.rmi.server.hostname=<hostname>
activemq
-</pre>
+]]></script>
</div></div>
</div>
</td>
@@ -102,8 +114,8 @@ activemq
<h3><a shape="rect" name="Navigation-Search"></a>Search</h3>
-
-<div>
+<p>
+</p><div>
<form enctype="application/x-www-form-urlencoded" method="get" action="http://www.google.com/search" style="font-size: 10px;">
<input type="hidden" name="ie" value="UTF-8">
<input type="hidden" name="oe" value="UTF-8">
Modified: websites/production/activemq/content/i-do-not-receive-messages-in-my-second-consumer.html
==============================================================================
--- websites/production/activemq/content/i-do-not-receive-messages-in-my-second-consumer.html (original)
+++ websites/production/activemq/content/i-do-not-receive-messages-in-my-second-consumer.html Fri Jul 12 12:46:14 2013
@@ -32,6 +32,7 @@
</style>
<![endif]-->
+
<title>
Apache ActiveMQ ™ -- I do not receive messages in my second consumer
</title>
@@ -50,8 +51,8 @@
<div>
<!-- Banner -->
-
- <div id="asf_logo">
+<p>
+ </p><div id="asf_logo">
<div id="activemq_logo">
<a shape="rect" style="float:left; width:280px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:10px; margin-left:100px;" href="http://activemq.apache.org" title="The most popular and powerful open source Message Broker">ActiveMQ</a> ™
<a shape="rect" style="float:right; width:210px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:15px; margin-right:10px;" href="http://www.apache.org" title="The Apache Software Foundation">ASF</a>
@@ -111,8 +112,8 @@
<h3><a shape="rect" name="Navigation-Search"></a>Search</h3>
-
-<div>
+<p>
+</p><div>
<form enctype="application/x-www-form-urlencoded" method="get" action="http://www.google.com/search" style="font-size: 10px;">
<input type="hidden" name="ie" value="UTF-8">
<input type="hidden" name="oe" value="UTF-8">
Modified: websites/production/activemq/content/i-get-errors-building-the-code-whats-wrong.html
==============================================================================
--- websites/production/activemq/content/i-get-errors-building-the-code-whats-wrong.html (original)
+++ websites/production/activemq/content/i-get-errors-building-the-code-whats-wrong.html Fri Jul 12 12:46:14 2013
@@ -32,6 +32,16 @@
</style>
<![endif]-->
+ <link href='http://activemq.apache.org/styles/highlighter/styles/shCore.css' rel='stylesheet' type='text/css' />
+ <link href='http://activemq.apache.org/styles/highlighter/styles/shThemeEclipse.css' rel='stylesheet' type='text/css' />
+ <script src='http://activemq.apache.org/styles/highlighter/scripts/shCore.js' type='text/javascript'></script>
+ <script src='http://activemq.apache.org/styles/highlighter/scripts/shBrushJava.js' type='text/javascript'></script>
+
+ <script type="text/javascript">
+ SyntaxHighlighter.defaults['toolbar'] = false;
+ SyntaxHighlighter.all();
+ </script>
+
<title>
Apache ActiveMQ ™ -- I get errors building the code whats wrong
</title>
@@ -50,8 +60,8 @@
<div>
<!-- Banner -->
-
- <div id="asf_logo">
+<p>
+ </p><div id="asf_logo">
<div id="activemq_logo">
<a shape="rect" style="float:left; width:280px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:10px; margin-left:100px;" href="http://activemq.apache.org" title="The most popular and powerful open source Message Broker">ActiveMQ</a> ™
<a shape="rect" style="float:right; width:210px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:15px; margin-right:10px;" href="http://www.apache.org" title="The Apache Software Foundation">ASF</a>
@@ -76,11 +86,11 @@
<p>We currently use a multi-project maven build system, which can be a little fragile. If you are ever having problems building we suggest you try the following in the root <em>activemq</em> directory</p>
<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
-<pre class="code-java">
+<script class="theme: Default; brush: java; gutter: false" type="syntaxhighlighter"><![CDATA[
mvn clean
rm -rf ~/.m2/repository
mvn
-</pre>
+]]></script>
</div></div>
<p>You may also want to <a shape="rect" href="how-do-i-build-but-disable-the-unit-tests.html" title="How do I build but disable the unit tests">disable the unit tests</a></p>
@@ -97,8 +107,8 @@ mvn
<h3><a shape="rect" name="Navigation-Search"></a>Search</h3>
-
-<div>
+<p>
+</p><div>
<form enctype="application/x-www-form-urlencoded" method="get" action="http://www.google.com/search" style="font-size: 10px;">
<input type="hidden" name="ie" value="UTF-8">
<input type="hidden" name="oe" value="UTF-8">
Modified: websites/production/activemq/content/i-see-nc-client-ids-what-does-that-mean.html
==============================================================================
--- websites/production/activemq/content/i-see-nc-client-ids-what-does-that-mean.html (original)
+++ websites/production/activemq/content/i-see-nc-client-ids-what-does-that-mean.html Fri Jul 12 12:46:14 2013
@@ -32,6 +32,7 @@
</style>
<![endif]-->
+
<title>
Apache ActiveMQ ™ -- I see NC_ client-ids, what does that mean?
</title>
@@ -50,8 +51,8 @@
<div>
<!-- Banner -->
-
- <div id="asf_logo">
+<p>
+ </p><div id="asf_logo">
<div id="activemq_logo">
<a shape="rect" style="float:left; width:280px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:10px; margin-left:100px;" href="http://activemq.apache.org" title="The most popular and powerful open source Message Broker">ActiveMQ</a> ™
<a shape="rect" style="float:right; width:210px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:15px; margin-right:10px;" href="http://www.apache.org" title="The Apache Software Foundation">ASF</a>
@@ -93,8 +94,8 @@ When a durable subscription is being for
<h3><a shape="rect" name="Navigation-Search"></a>Search</h3>
-
-<div>
+<p>
+</p><div>
<form enctype="application/x-www-form-urlencoded" method="get" action="http://www.google.com/search" style="font-size: 10px;">
<input type="hidden" name="ie" value="UTF-8">
<input type="hidden" name="oe" value="UTF-8">
Modified: websites/production/activemq/content/ideas.html
==============================================================================
--- websites/production/activemq/content/ideas.html (original)
+++ websites/production/activemq/content/ideas.html Fri Jul 12 12:46:14 2013
@@ -32,6 +32,7 @@
</style>
<![endif]-->
+
<title>
Apache ActiveMQ ™ -- Ideas
</title>
@@ -50,8 +51,8 @@
<div>
<!-- Banner -->
-
- <div id="asf_logo">
+<p>
+ </p><div id="asf_logo">
<div id="activemq_logo">
<a shape="rect" style="float:left; width:280px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:10px; margin-left:100px;" href="http://activemq.apache.org" title="The most popular and powerful open source Message Broker">ActiveMQ</a> ™
<a shape="rect" style="float:right; width:210px;display:block;text-indent:-5000px;text-decoration:none;line-height:60px; margin-top:15px; margin-right:10px;" href="http://www.apache.org" title="The Apache Software Foundation">ASF</a>
@@ -91,8 +92,8 @@
<h3><a shape="rect" name="Navigation-Search"></a>Search</h3>
-
-<div>
+<p>
+</p><div>
<form enctype="application/x-www-form-urlencoded" method="get" action="http://www.google.com/search" style="font-size: 10px;">
<input type="hidden" name="ie" value="UTF-8">
<input type="hidden" name="oe" value="UTF-8">