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 [18/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/jms-and-jdbc-operations-in-one-transaction.html
==============================================================================
--- websites/production/activemq/content/jms-and-jdbc-operations-in-one-transaction.html (original)
+++ websites/production/activemq/content/jms-and-jdbc-operations-in-one-transaction.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 ™ -- JMS and JDBC operations in one transaction
</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>
@@ -76,155 +87,155 @@
<p>Spring beans:</p>
<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
-<pre class="code-xml">
-<span class="code-tag"><beans></span>
- <span class="code-tag"><span class="code-comment"><!-- ActiveMQ Broker --></span></span>
- <span class="code-tag"><bean id=<span class="code-quote">"broker"</span> class=<span class="code-quote">"org.apache.activemq.broker.BrokerService"</span> init-method=<span class="code-quote">"start"</span> destroy-method=<span class="code-quote">"stop"</span>></span>
- <span class="code-tag"><property name=<span class="code-quote">"persistent"</span> value=<span class="code-quote">"false"</span>/></span>
- <span class="code-tag"><property name=<span class="code-quote">"transportConnectorURIs"</span>></span>
- <span class="code-tag"><list></span>
- <span class="code-tag"><value></span>tcp://localhost:5000<span class="code-tag"></value></span>
- <span class="code-tag"></list></span>
- <span class="code-tag"></property></span>
- <span class="code-tag"></bean></span>
-
- <span class="code-tag"><span class="code-comment"><!-- Geronimo Transaction Manager --></span></span>
- <span class="code-tag"><bean id=<span class="code-quote">"transactionContextManager"</span> class=<span class="code-quote">"org.jencks.factory.TransactionContextManagerFactoryBean"</span>/></span>
- <span class="code-tag"><bean id=<span class="code-quote">"geronimo"</span> class=<span class="code-quote">"org.jencks.factory.GeronimoTransactionManagerFactoryBean"</span>/></span>
- <span class="code-tag"><bean id=<span class="code-quote">"geronimoTransactionManager"</span> class=<span class="code-quote">"org.springframework.transaction.jta.JtaTransactionManager"</span>></span>
- <span class="code-tag"><property name=<span class="code-quote">"userTransaction"</span> ref=<span class="code-quote">"geronimo"</span> /></span>
- <span class="code-tag"></bean></span>
-
- <span class="code-tag"><span class="code-comment"><!-- Jencks Connection Manager --></span></span>
- <span class="code-tag"><bean id=<span class="code-quote">"connectionManager"</span> class=<span class="code-quote">"org.jencks.factory.ConnectionManagerFactoryBean"</span>></span>
- <span class="code-tag"><property name=<span class="code-quote">"transactionSupport"</span>></span>
- <span class="code-tag"><bean class=<span class="code-quote">"org.jencks.factory.XATransactionFactoryBean"</span>></span>
- <span class="code-tag"><property name=<span class="code-quote">"useTransactionCaching"</span> value=<span class="code-quote">"true"</span>/></span>
- <span class="code-tag"><property name=<span class="code-quote">"useThreadCaching"</span> value=<span class="code-quote">"false"</span>/></span>
- <span class="code-tag"></bean></span>
- <span class="code-tag"></property></span>
- <span class="code-tag"><property name=<span class="code-quote">"poolingSupport"</span>></span>
- <span class="code-tag"><bean class=<span class="code-quote">"org.jencks.factory.SinglePoolFactoryBean"</span>></span>
- <span class="code-tag"><property name=<span class="code-quote">"maxSize"</span> value=<span class="code-quote">"2"</span>/></span>
- <span class="code-tag"><property name=<span class="code-quote">"minSize"</span> value=<span class="code-quote">"1"</span>/></span>
- <span class="code-tag"><property name=<span class="code-quote">"blockingTimeoutMilliseconds"</span> value=<span class="code-quote">"60"</span>/></span>
- <span class="code-tag"><property name=<span class="code-quote">"idleTimeoutMinutes"</span> value=<span class="code-quote">"60"</span>/></span>
- <span class="code-tag"><property name=<span class="code-quote">"matchOne"</span> value=<span class="code-quote">"true"</span>/></span>
- <span class="code-tag"><property name=<span class="code-quote">"matchAll"</span> value=<span class="code-quote">"true"</span>/></span>
- <span class="code-tag"><property name=<span class="code-quote">"selectOneAssumeMatch"</span> value=<span class="code-quote">"true"</span>/></span>
- <span class="code-tag"></bean></span>
- <span class="code-tag"></property></span>
- <span class="code-tag"></bean></span>
-
- <span class="code-tag"><span class="code-comment"><!-- ActiveMQ Connection --></span></span>
- <span class="code-tag"><bean id=<span class="code-quote">"jmsResourceAdapter"</span> class=<span class="code-quote">"org.apache.activemq.ra.ActiveMQResourceAdapter"</span> depends-on=<span class="code-quote">"broker"</span>></span>
- <span class="code-tag"><property name=<span class="code-quote">"serverUrl"</span>></span>
- <span class="code-tag"><value></span>tcp://localhost:5000<span class="code-tag"></value></span>
- <span class="code-tag"></property></span>
- <span class="code-tag"></bean></span>
- <span class="code-tag"><bean id=<span class="code-quote">"jmsManagedConnectionFactory"</span> class=<span class="code-quote">"org.apache.activemq.ra.ActiveMQManagedConnectionFactory"</span>></span>
- <span class="code-tag"><property name=<span class="code-quote">"resourceAdapter"</span> ref=<span class="code-quote">"jmsResourceAdapter"</span>/></span>
- <span class="code-tag"></bean></span>
- <span class="code-tag"><bean id=<span class="code-quote">"jmsConnectionFactory"</span> class=<span class="code-quote">"org.springframework.jca.support.LocalConnectionFactoryBean"</span>></span>
- <span class="code-tag"><property name=<span class="code-quote">"managedConnectionFactory"</span> ref=<span class="code-quote">"jmsManagedConnectionFactory"</span>/></span>
- <span class="code-tag"><property name=<span class="code-quote">"connectionManager"</span> ref=<span class="code-quote">"connectionManager"</span>/></span>
- <span class="code-tag"></bean></span>
+<script class="theme: Default; brush: xml; gutter: false" type="syntaxhighlighter"><![CDATA[
+<beans>
+ <!-- ActiveMQ Broker -->
+ <bean id="broker" class="org.apache.activemq.broker.BrokerService" init-method="start" destroy-method="stop">
+ <property name="persistent" value="false"/>
+ <property name="transportConnectorURIs">
+ <list>
+ <value>tcp://localhost:5000</value>
+ </list>
+ </property>
+ </bean>
+
+ <!-- Geronimo Transaction Manager -->
+ <bean id="transactionContextManager" class="org.jencks.factory.TransactionContextManagerFactoryBean"/>
+ <bean id="geronimo" class="org.jencks.factory.GeronimoTransactionManagerFactoryBean"/>
+ <bean id="geronimoTransactionManager" class="org.springframework.transaction.jta.JtaTransactionManager">
+ <property name="userTransaction" ref="geronimo" />
+ </bean>
+
+ <!-- Jencks Connection Manager -->
+ <bean id="connectionManager" class="org.jencks.factory.ConnectionManagerFactoryBean">
+ <property name="transactionSupport">
+ <bean class="org.jencks.factory.XATransactionFactoryBean">
+ <property name="useTransactionCaching" value="true"/>
+ <property name="useThreadCaching" value="false"/>
+ </bean>
+ </property>
+ <property name="poolingSupport">
+ <bean class="org.jencks.factory.SinglePoolFactoryBean">
+ <property name="maxSize" value="2"/>
+ <property name="minSize" value="1"/>
+ <property name="blockingTimeoutMilliseconds" value="60"/>
+ <property name="idleTimeoutMinutes" value="60"/>
+ <property name="matchOne" value="true"/>
+ <property name="matchAll" value="true"/>
+ <property name="selectOneAssumeMatch" value="true"/>
+ </bean>
+ </property>
+ </bean>
+
+ <!-- ActiveMQ Connection -->
+ <bean id="jmsResourceAdapter" class="org.apache.activemq.ra.ActiveMQResourceAdapter" depends-on="broker">
+ <property name="serverUrl">
+ <value>tcp://localhost:5000</value>
+ </property>
+ </bean>
+ <bean id="jmsManagedConnectionFactory" class="org.apache.activemq.ra.ActiveMQManagedConnectionFactory">
+ <property name="resourceAdapter" ref="jmsResourceAdapter"/>
+ </bean>
+ <bean id="jmsConnectionFactory" class="org.springframework.jca.support.LocalConnectionFactoryBean">
+ <property name="managedConnectionFactory" ref="jmsManagedConnectionFactory"/>
+ <property name="connectionManager" ref="connectionManager"/>
+ </bean>
- <span class="code-tag"><span class="code-comment"><!-- Tranql JDBC Connection --></span></span>
+ <!-- Tranql JDBC Connection -->
<!--
- <span class="code-tag"><bean id=<span class="code-quote">"tranqlManagedConnectionFactory"</span> class=<span class="code-quote">"org.jencks.tranql.XAPoolDataSourceMCF"</span>></span>
- <span class="code-tag"><property name=<span class="code-quote">"driverName"</span> value=<span class="code-quote">"org.postgresql.Driver"</span>/></span>
- <span class="code-tag"><property name=<span class="code-quote">"url"</span> value=<span class="code-quote">"jdbc:postgresql://ats-manager/activemq"</span>/></span>
- <span class="code-tag"><property name=<span class="code-quote">"user"</span> value=<span class="code-quote">"activemq"</span>/></span>
- <span class="code-tag"></bean></span>
- <span class="code-tag"><bean id=<span class="code-quote">"tranqlDataSource"</span> class=<span class="code-quote">"org.springframework.jca.support.LocalConnectionFactoryBean"</span>></span>
- <span class="code-tag"><property name=<span class="code-quote">"managedConnectionFactory"</span> ref=<span class="code-quote">"tranqlManagedConnectionFactory"</span>/></span>
- <span class="code-tag"><property name=<span class="code-quote">"connectionManager"</span> ref=<span class="code-quote">"connectionManager"</span>/></span>
- <span class="code-tag"></bean></span>
+ <bean id="tranqlManagedConnectionFactory" class="org.jencks.tranql.XAPoolDataSourceMCF">
+ <property name="driverName" value="org.postgresql.Driver"/>
+ <property name="url" value="jdbc:postgresql://ats-manager/activemq"/>
+ <property name="user" value="activemq"/>
+ </bean>
+ <bean id="tranqlDataSource" class="org.springframework.jca.support.LocalConnectionFactoryBean">
+ <property name="managedConnectionFactory" ref="tranqlManagedConnectionFactory"/>
+ <property name="connectionManager" ref="connectionManager"/>
+ </bean>
-->
- <span class="code-tag"><span class="code-comment"><!-- Enhydra JDBC Connection --></span></span>
- <span class="code-tag"><bean id=<span class="code-quote">"enhydraDataSource"</span> class=<span class="code-quote">"org.enhydra.jdbc.pool.StandardXAPoolDataSource"</span> destroy-method=<span class="code-quote">"shutdown"</span>></span>
- <span class="code-tag"><property name=<span class="code-quote">"dataSource"</span>></span>
- <span class="code-tag"><bean class=<span class="code-quote">"org.enhydra.jdbc.standard.StandardXADataSource"</span> destroy-method=<span class="code-quote">"shutdown"</span>></span>
- <span class="code-tag"><property name=<span class="code-quote">"transactionManager"</span> ref=<span class="code-quote">"geronimo"</span> /></span>
- <span class="code-tag"><property name=<span class="code-quote">"driverName"</span> value=<span class="code-quote">"org.postgresql.Driver"</span> /></span>
- <span class="code-tag"><property name=<span class="code-quote">"url"</span> value=<span class="code-quote">"jdbc:postgresql://ats-manager/activemq"</span> /></span>
- <span class="code-tag"></bean></span>
- <span class="code-tag"></property></span>
- <span class="code-tag"><property name=<span class="code-quote">"user"</span> value=<span class="code-quote">"activemq"</span>/></span>
- <span class="code-tag"></bean></span>
-
- <span class="code-tag"><bean id=<span class="code-quote">"jencksJCAContainer"</span> class=<span class="code-quote">"org.jencks.JCAContainer"</span>></span>
- <span class="code-tag"><property name=<span class="code-quote">"bootstrapContext"</span>></span>
- <span class="code-tag"><bean class=<span class="code-quote">"org.jencks.factory.BootstrapContextFactoryBean"</span>></span>
- <span class="code-tag"><property name=<span class="code-quote">"threadPoolSize"</span> value=<span class="code-quote">"25"</span>/></span>
- <span class="code-tag"></bean></span>
- <span class="code-tag"></property></span>
- <span class="code-tag"><property name=<span class="code-quote">"resourceAdapter"</span> ref=<span class="code-quote">"jmsResourceAdapter"</span>/></span>
- <span class="code-tag"></bean></span>
-
- <span class="code-tag"><bean id=<span class="code-quote">"inboundConnector"</span> class=<span class="code-quote">"org.jencks.JCAConnector"</span>></span>
- <span class="code-tag"><property name=<span class="code-quote">"jcaContainer"</span> ref=<span class="code-quote">"jencksJCAContainer"</span> /></span>
- <span class="code-tag"><property name=<span class="code-quote">"activationSpec"</span>></span>
- <span class="code-tag"><bean class=<span class="code-quote">"org.apache.activemq.ra.ActiveMQActivationSpec"</span>></span>
- <span class="code-tag"><property name=<span class="code-quote">"destination"</span> value=<span class="code-quote">"messages.input"</span>/></span>
- <span class="code-tag"><property name=<span class="code-quote">"destinationType"</span> value=<span class="code-quote">"javax.jms.Queue"</span>/></span>
- <span class="code-tag"></bean></span>
- <span class="code-tag"></property></span>
- <span class="code-tag"><property name=<span class="code-quote">"transactionManager"</span> ref=<span class="code-quote">"geronimo"</span>/></span>
- <span class="code-tag"><property name=<span class="code-quote">"ref"</span> value=<span class="code-quote">"echoBean"</span>/></span>
- <span class="code-tag"></bean></span>
-
- <span class="code-tag"><bean id=<span class="code-quote">"echoBean"</span> class=<span class="code-quote">"transactions.EchoBean"</span>></span>
- <span class="code-tag"><property name=<span class="code-quote">"jdbcTemplate"</span>></span>
- <span class="code-tag"><bean class=<span class="code-quote">"org.springframework.jdbc.core.JdbcTemplate"</span>></span>
- <span class="code-tag"><property name=<span class="code-quote">"dataSource"</span> ref=<span class="code-quote">"enhydraDataSource"</span>/></span>
- <span class="code-tag"></bean></span>
- <span class="code-tag"></property></span>
- <span class="code-tag"><property name=<span class="code-quote">"jmsTemplate"</span>></span>
- <span class="code-tag"><bean class=<span class="code-quote">"org.springframework.jms.core.JmsTemplate"</span>></span>
- <span class="code-tag"><property name=<span class="code-quote">"connectionFactory"</span> ref=<span class="code-quote">"jmsConnectionFactory"</span>/></span>
- <span class="code-tag"></bean></span>
- <span class="code-tag"></property></span>
- <span class="code-tag"></bean></span>
-<span class="code-tag"></beans></span>
-</pre>
+ <!-- Enhydra JDBC Connection -->
+ <bean id="enhydraDataSource" class="org.enhydra.jdbc.pool.StandardXAPoolDataSource" destroy-method="shutdown">
+ <property name="dataSource">
+ <bean class="org.enhydra.jdbc.standard.StandardXADataSource" destroy-method="shutdown">
+ <property name="transactionManager" ref="geronimo" />
+ <property name="driverName" value="org.postgresql.Driver" />
+ <property name="url" value="jdbc:postgresql://ats-manager/activemq" />
+ </bean>
+ </property>
+ <property name="user" value="activemq"/>
+ </bean>
+
+ <bean id="jencksJCAContainer" class="org.jencks.JCAContainer">
+ <property name="bootstrapContext">
+ <bean class="org.jencks.factory.BootstrapContextFactoryBean">
+ <property name="threadPoolSize" value="25"/>
+ </bean>
+ </property>
+ <property name="resourceAdapter" ref="jmsResourceAdapter"/>
+ </bean>
+
+ <bean id="inboundConnector" class="org.jencks.JCAConnector">
+ <property name="jcaContainer" ref="jencksJCAContainer" />
+ <property name="activationSpec">
+ <bean class="org.apache.activemq.ra.ActiveMQActivationSpec">
+ <property name="destination" value="messages.input"/>
+ <property name="destinationType" value="javax.jms.Queue"/>
+ </bean>
+ </property>
+ <property name="transactionManager" ref="geronimo"/>
+ <property name="ref" value="echoBean"/>
+ </bean>
+
+ <bean id="echoBean" class="transactions.EchoBean">
+ <property name="jdbcTemplate">
+ <bean class="org.springframework.jdbc.core.JdbcTemplate">
+ <property name="dataSource" ref="enhydraDataSource"/>
+ </bean>
+ </property>
+ <property name="jmsTemplate">
+ <bean class="org.springframework.jms.core.JmsTemplate">
+ <property name="connectionFactory" ref="jmsConnectionFactory"/>
+ </bean>
+ </property>
+ </bean>
+</beans>
+]]></script>
</div></div>
<p>Java code:</p>
<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
-<pre class="code-java">
-<span class="code-keyword">public</span> class EchoBean <span class="code-keyword">implements</span> MessageListener {
+<script class="theme: Default; brush: java; gutter: false" type="syntaxhighlighter"><![CDATA[
+public class EchoBean implements MessageListener {
- <span class="code-keyword">private</span> Log log = LogFactory.getLog(getClass());
+ private Log log = LogFactory.getLog(getClass());
- <span class="code-keyword">private</span> JdbcTemplate jdbcTemplate;
- <span class="code-keyword">private</span> JmsTemplate jmsTemplate;
+ private JdbcTemplate jdbcTemplate;
+ private JmsTemplate jmsTemplate;
- <span class="code-keyword">public</span> void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
- <span class="code-keyword">this</span>.jdbcTemplate = jdbcTemplate;
+ public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
+ this.jdbcTemplate = jdbcTemplate;
}
- <span class="code-keyword">public</span> void setJmsTemplate(JmsTemplate jmsTemplate) {
- <span class="code-keyword">this</span>.jmsTemplate = jmsTemplate;
+ public void setJmsTemplate(JmsTemplate jmsTemplate) {
+ this.jmsTemplate = jmsTemplate;
}
- <span class="code-keyword">public</span> void onMessage(Message message) {
+ public void onMessage(Message message) {
log.debug(message);
- <span class="code-keyword">if</span> (message <span class="code-keyword">instanceof</span> TextMessage) {
- <span class="code-keyword">try</span> {
- <span class="code-object">String</span> messageText = ((TextMessage)message).getText();
- log.debug(<span class="code-quote">"execute JMS operation"</span>);
- jmsTemplate.convertAndSend(<span class="code-quote">"messages.ouptut"</span>, messageText);
- log.debug(<span class="code-quote">"execute JDBC operation"</span>);
- jdbcTemplate.execute(<span class="code-quote">"insert into t1 values('"</span>+messageText+<span class="code-quote">"')"</span>);
- } <span class="code-keyword">catch</span> (JMSException e) {
+ if (message instanceof TextMessage) {
+ try {
+ String messageText = ((TextMessage)message).getText();
+ log.debug("execute JMS operation");
+ jmsTemplate.convertAndSend("messages.ouptut", messageText);
+ log.debug("execute JDBC operation");
+ jdbcTemplate.execute("insert into t1 values('"+messageText+"')");
+ } catch (JMSException e) {
e.printStackTrace();
}
}
}
}
-</pre>
+]]></script>
</div></div>
</div>
</td>
@@ -239,8 +250,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/jms-bridge-with-local-broker.html
==============================================================================
--- websites/production/activemq/content/jms-bridge-with-local-broker.html (original)
+++ websites/production/activemq/content/jms-bridge-with-local-broker.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 ™ -- JMS Bridge With Local Broker
</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>
@@ -75,37 +86,37 @@
<h3><a shape="rect" name="JMSBridgeWithLocalBroker-ExampleofaconfigurationthatshowshowtouseaBridgeConnectortomakeaconnectiontothelocalActiveMQbroker."></a>Example of a configuration that shows how to use a BridgeConnector to make a connection to the local ActiveMQ broker.</h3>
<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
-<pre class="code-xml">
-<span class="code-tag"><beans></span>
- <span class="code-tag"><span class="code-comment"><!-- Allows us to use system properties as variables in this configuration file --></span></span>
- <span class="code-tag"><bean class=<span class="code-quote">"org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"</span>/></span>
-
- <broker useJmx=<span class="code-quote">"true"</span> persistent=<span class="code-quote">"false"</span> xmlns=<span class="code-quote">"http://activemq.org/config/1.0"</span>
- brokerName=<span class="code-quote">"localhost"</span> dataDirectory=<span class="code-quote">"${activemq.base}/data"</span>>
- <span class="code-tag"><jmsBridgeConnectors></span>
- <span class="code-tag"><jmsQueueConnector outboundQueueConnectionFactory=<span class="code-quote">"#localBroker"</span>></span>
- <span class="code-tag"><inboundQueueBridges></span>
+<script class="theme: Default; brush: xml; gutter: false" type="syntaxhighlighter"><![CDATA[
+<beans>
+ <!-- Allows us to use system properties as variables in this configuration file -->
+ <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
+
+ <broker useJmx="true" persistent="false" xmlns="http://activemq.org/config/1.0"
+ brokerName="localhost" dataDirectory="${activemq.base}/data">
+ <jmsBridgeConnectors>
+ <jmsQueueConnector outboundQueueConnectionFactory="#localBroker">
+ <inboundQueueBridges>
<inboundQueueBridge
- inboundQueueName = <span class="code-quote">"queue.ping"</span>
- localQueueName = <span class="code-quote">"queue.incomingMsgs.ping"</span>
- selector = <span class="code-quote">"JMSType LIKE 'foo%'"</span>/>
- <span class="code-tag"></inboundQueueBridges></span>
- <span class="code-tag"><outboundQueueBridges></span>
+ inboundQueueName = "queue.ping"
+ localQueueName = "queue.incomingMsgs.ping"
+ selector = "JMSType LIKE 'foo%'"/>
+ </inboundQueueBridges>
+ <outboundQueueBridges>
<outboundQueueBridge
- localQueueName = <span class="code-quote">"queue.incomingMsgs.ping"</span>
- outboundQueueName = <span class="code-quote">"queue.pong"</span>
- selector = <span class="code-quote">"JMSType LIKE 'foo%'"</span>/>
- <span class="code-tag"></outboundQueueBridges></span>
- <span class="code-tag"></jmsQueueConnector></span>
- <span class="code-tag"></jmsBridgeConnectors></span>
- <span class="code-tag"></broker></span>
-
- <span class="code-tag"><span class="code-comment"><!-- JMS ConnectionFactory to use for local bridging --></span></span>
- <span class="code-tag"><bean id=<span class="code-quote">"localBroker"</span> class=<span class="code-quote">"org.apache.activemq.ActiveMQConnectionFactory"</span>></span>
- <span class="code-tag"><property name=<span class="code-quote">"brokerURL"</span> value=<span class="code-quote">"vm://localhost:61616"</span> /></span>
- <span class="code-tag"></bean></span>
-<span class="code-tag"></beans></span>
-</pre>
+ localQueueName = "queue.incomingMsgs.ping"
+ outboundQueueName = "queue.pong"
+ selector = "JMSType LIKE 'foo%'"/>
+ </outboundQueueBridges>
+ </jmsQueueConnector>
+ </jmsBridgeConnectors>
+ </broker>
+
+ <!-- JMS ConnectionFactory to use for local bridging -->
+ <bean id="localBroker" class="org.apache.activemq.ActiveMQConnectionFactory">
+ <property name="brokerURL" value="vm://localhost:61616" />
+ </bean>
+</beans>
+]]></script>
</div></div>
</div>
</td>
@@ -120,8 +131,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/jms-bridge-with-oracle-aq.html
==============================================================================
--- websites/production/activemq/content/jms-bridge-with-oracle-aq.html (original)
+++ websites/production/activemq/content/jms-bridge-with-oracle-aq.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 ™ -- JMS Bridge With Oracle AQ
</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>
@@ -75,95 +86,95 @@
<h3><a shape="rect" name="JMSBridgeWithOracleAQ-ExampleofaconfigurationthatshowshowtoconnecttoOracleAQqueuesandtopics."></a>Example of a configuration that shows how to connect to Oracle AQ queues and topics.</h3>
<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
-<pre class="code-xml">
-<span class="code-tag"><beans></span>
- <span class="code-tag"><span class="code-comment"><!-- Allows us to use system properties as variables in this configuration file --></span></span>
- <span class="code-tag"><bean class=<span class="code-quote">"org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"</span>/></span>
-
- <broker useJmx=<span class="code-quote">"true"</span> persistent=<span class="code-quote">"false"</span> xmlns=<span class="code-quote">"http://activemq.org/config/1.0"</span>
- brokerName=<span class="code-quote">"localhost"</span> dataDirectory=<span class="code-quote">"${activemq.base}/data"</span> >
- <span class="code-tag"></broker></span>
-
- <span class="code-tag"><camelContext id=<span class="code-quote">"camel"</span> xmlns=<span class="code-quote">"http://activemq.apache.org/camel/schema/spring"</span>></span>
- <span class="code-tag"><span class="code-comment"><!-- Dependencies: ojdbc.jar and aqjms.jar must be in the activemq lib directory --></span></span>
-
- <span class="code-tag"><span class="code-comment"><!-- this camel route will read incoming messages from Oracle --></span></span>
- <span class="code-tag"><route></span>
- <span class="code-tag"><from uri=<span class="code-quote">"oracleQueue:queue:ORACLE_QUEUE"</span>></span>
- <span class="code-tag"><to uri=<span class="code-quote">"activemq:queue:queue.inboundOracleAQqueue"</span> ></span>
- <span class="code-tag"></route></span>
- <span class="code-tag"><route></span>
- <span class="code-tag"><span class="code-comment"><!-- NOTE: I have had success with a topic using ActiveMQ 5.3, but not 5.1 --></span></span>
- <span class="code-tag"><from uri=<span class="code-quote">"oracleTopic:topic:ORACLE_TOPIC"</span>></span>
- <span class="code-tag"><to uri=<span class="code-quote">"activemq:queue:queue.inboundOracleAQtopic"</span> ></span>
- <span class="code-tag"></route></span>
-
- <span class="code-tag"><span class="code-comment"><!-- these camel routes will log the messages to the console .... replace them with something more useful!! --></span></span>
- <span class="code-tag"><route></span>
- <span class="code-tag"><from uri=<span class="code-quote">"activemq:queue:queue.inboundOracleAQqueue"</span> ></span>
- <span class="code-tag"><to uri=<span class="code-quote">"log:oracleAQ.inbound.got_a_queue_message?level=ERROR"</span>></span>
- <span class="code-tag"></route></span>
- <span class="code-tag"><route></span>
- <span class="code-tag"><from uri=<span class="code-quote">"activemq:queue:queue.inboundOracleAQtopic"</span> ></span>
- <span class="code-tag"><to uri=<span class="code-quote">"log:oracleAQ.inbound.got_a_topic_message?level=ERROR"</span>></span>
- <span class="code-tag"></route></span>
- <span class="code-tag"></camelContext></span>
-
- <span class="code-tag"><span class="code-comment"><!-- without the following bean instantiation, we will get an oracle.jms.AQjmsException with each and every received message --></span></span>
- <span class="code-tag"><bean id=<span class="code-quote">"requiredBeanForOracleAq"</span> class=<span class="code-quote">"org.apache.activemq.ActiveMQConnectionFactory"</span> /></span>
-
- <span class="code-tag"><bean id=<span class="code-quote">"connectionFactoryOracleAQQueue"</span> class=<span class="code-quote">"oracle.jms.AQjmsFactory"</span> factory-method=<span class="code-quote">"getQueueConnectionFactory"</span>></span>
- <span class="code-tag"><constructor-arg index=<span class="code-quote">"0"</span>></span>
- <span class="code-tag"><value></span>jdbc:oracle:thin:@(DESCRIPTION =(ADDRESS_LIST ....... (SERVICE_NAME = myDbService)))<span class="code-tag"></value></span>
- <span class="code-tag"></constructor-arg></span>
- <span class="code-tag"><constructor-arg index=<span class="code-quote">"1"</span> type=<span class="code-quote">"java.util.Properties"</span>></span>
- <span class="code-tag"><value></span><span class="code-tag"></value></span>
- <span class="code-tag"></constructor-arg></span>
- <span class="code-tag"></bean></span>
-
- <bean id=<span class="code-quote">"connectionFactoryOracleAQTopic"</span> class=<span class="code-quote">"oracle.jms.AQjmsFactory"</span>
- factory-method=<span class="code-quote">"getQueueConnectionFactory"</span>>
- <span class="code-tag"><constructor-arg index=<span class="code-quote">"0"</span>></span>
- <span class="code-tag"><value></span>jdbc:oracle:thin:@(DESCRIPTION =(ADDRESS_LIST ....... (SERVICE_NAME = myDbService)))<span class="code-tag"></value></span>
- <span class="code-tag"></constructor-arg></span>
- <span class="code-tag"><constructor-arg index=<span class="code-quote">"1"</span> type=<span class="code-quote">"java.util.Properties"</span>></span>
- <span class="code-tag"><value></span><span class="code-tag"></value></span>
- <span class="code-tag"></constructor-arg></span>
- <span class="code-tag"></bean></span>
-
- <span class="code-tag"><bean id=<span class="code-quote">"oracleQueueCredentials"</span> class=<span class="code-quote">"org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter"</span>></span>
- <span class="code-tag"><property name=<span class="code-quote">"targetConnectionFactory"</span>></span>
- <span class="code-tag"><ref bean=<span class="code-quote">"connectionFactoryOracleAQQueue"</span>></span>
- <span class="code-tag"></property></span>
- <span class="code-tag"><property name=<span class="code-quote">"username"</span>></span>
- <span class="code-tag"><value></span>foo<span class="code-tag"></value></span>
- <span class="code-tag"></property></span>
- <span class="code-tag"><property name=<span class="code-quote">"password"</span>></span>
- <span class="code-tag"><value></span>bar<span class="code-tag"></value></span>
- <span class="code-tag"></property></span>
- <span class="code-tag"></bean></span>
-
- <span class="code-tag"><bean id=<span class="code-quote">"oracleTopicCredentials"</span> class=<span class="code-quote">"org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter"</span>></span>
- <span class="code-tag"><property name=<span class="code-quote">"targetConnectionFactory"</span>></span>
- <span class="code-tag"><ref bean=<span class="code-quote">"connectionFactoryOracleAQTopic"</span>></span>
- <span class="code-tag"></property></span>
- <span class="code-tag"><property name=<span class="code-quote">"username"</span>></span>
- <span class="code-tag"><value></span>foo<span class="code-tag"></value></span>
- <span class="code-tag"></property></span>
- <span class="code-tag"><property name=<span class="code-quote">"password"</span>></span>
- <span class="code-tag"><value></span>bar<span class="code-tag"></value></span>
- <span class="code-tag"></property></span>
- <span class="code-tag"></bean></span>
-
- <span class="code-tag"><bean id=<span class="code-quote">"oracleQueue"</span> class=<span class="code-quote">"org.apache.camel.component.jms.JmsComponent"</span>></span>
- <span class="code-tag"><property name=<span class="code-quote">"connectionFactory"</span> ref=<span class="code-quote">"oracleQueueCredentials"</span>></span>
- <span class="code-tag"></bean></span>
-
- <span class="code-tag"><bean id=<span class="code-quote">"oracleTopic"</span> class=<span class="code-quote">"org.apache.camel.component.jms.JmsComponent"</span>></span>
- <span class="code-tag"><property name=<span class="code-quote">"connectionFactory"</span> ref=<span class="code-quote">"oracleTopicCredentials"</span>></span>
- <span class="code-tag"></bean></span>
-<span class="code-tag"></beans></span>
-</pre>
+<script class="theme: Default; brush: xml; gutter: false" type="syntaxhighlighter"><![CDATA[
+<beans>
+ <!-- Allows us to use system properties as variables in this configuration file -->
+ <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
+
+ <broker useJmx="true" persistent="false" xmlns="http://activemq.org/config/1.0"
+ brokerName="localhost" dataDirectory="${activemq.base}/data" >
+ </broker>
+
+ <camelContext id="camel" xmlns="http://activemq.apache.org/camel/schema/spring">
+ <!-- Dependencies: ojdbc.jar and aqjms.jar must be in the activemq lib directory -->
+
+ <!-- this camel route will read incoming messages from Oracle -->
+ <route>
+ <from uri="oracleQueue:queue:ORACLE_QUEUE">
+ <to uri="activemq:queue:queue.inboundOracleAQqueue" >
+ </route>
+ <route>
+ <!-- NOTE: I have had success with a topic using ActiveMQ 5.3, but not 5.1 -->
+ <from uri="oracleTopic:topic:ORACLE_TOPIC">
+ <to uri="activemq:queue:queue.inboundOracleAQtopic" >
+ </route>
+
+ <!-- these camel routes will log the messages to the console .... replace them with something more useful!! -->
+ <route>
+ <from uri="activemq:queue:queue.inboundOracleAQqueue" >
+ <to uri="log:oracleAQ.inbound.got_a_queue_message?level=ERROR">
+ </route>
+ <route>
+ <from uri="activemq:queue:queue.inboundOracleAQtopic" >
+ <to uri="log:oracleAQ.inbound.got_a_topic_message?level=ERROR">
+ </route>
+ </camelContext>
+
+ <!-- without the following bean instantiation, we will get an oracle.jms.AQjmsException with each and every received message -->
+ <bean id="requiredBeanForOracleAq" class="org.apache.activemq.ActiveMQConnectionFactory" />
+
+ <bean id="connectionFactoryOracleAQQueue" class="oracle.jms.AQjmsFactory" factory-method="getQueueConnectionFactory">
+ <constructor-arg index="0">
+ <value>jdbc:oracle:thin:@(DESCRIPTION =(ADDRESS_LIST ....... (SERVICE_NAME = myDbService)))</value>
+ </constructor-arg>
+ <constructor-arg index="1" type="java.util.Properties">
+ <value></value>
+ </constructor-arg>
+ </bean>
+
+ <bean id="connectionFactoryOracleAQTopic" class="oracle.jms.AQjmsFactory"
+ factory-method="getQueueConnectionFactory">
+ <constructor-arg index="0">
+ <value>jdbc:oracle:thin:@(DESCRIPTION =(ADDRESS_LIST ....... (SERVICE_NAME = myDbService)))</value>
+ </constructor-arg>
+ <constructor-arg index="1" type="java.util.Properties">
+ <value></value>
+ </constructor-arg>
+ </bean>
+
+ <bean id="oracleQueueCredentials" class="org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter">
+ <property name="targetConnectionFactory">
+ <ref bean="connectionFactoryOracleAQQueue">
+ </property>
+ <property name="username">
+ <value>foo</value>
+ </property>
+ <property name="password">
+ <value>bar</value>
+ </property>
+ </bean>
+
+ <bean id="oracleTopicCredentials" class="org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter">
+ <property name="targetConnectionFactory">
+ <ref bean="connectionFactoryOracleAQTopic">
+ </property>
+ <property name="username">
+ <value>foo</value>
+ </property>
+ <property name="password">
+ <value>bar</value>
+ </property>
+ </bean>
+
+ <bean id="oracleQueue" class="org.apache.camel.component.jms.JmsComponent">
+ <property name="connectionFactory" ref="oracleQueueCredentials">
+ </bean>
+
+ <bean id="oracleTopic" class="org.apache.camel.component.jms.JmsComponent">
+ <property name="connectionFactory" ref="oracleTopicCredentials">
+ </bean>
+</beans>
+]]></script>
</div></div>
@@ -172,7 +183,7 @@
<h4><a shape="rect" name="JMSBridgeWithOracleAQ-OracleSQLcode"></a>Oracle SQL code</h4>
<p>You may need to setup OracleAQ, and here is a sample code</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[
BEGIN
DBMS_AQADM.CREATE_QUEUE_TABLE( queue_table => 'queue_message_table', queue_payload_type => 'SYS.AQ$_JMS_TEXT_MESSAGE');
END;
@@ -184,7 +195,7 @@ END;
BEGIN
DBMS_AQADM.START_QUEUE(queue_name => 'ORACLE_QUEUE');
END;
-</pre>
+]]></script>
</div></div>
<p>You can also find more information about OracleAQ and using JMS at: <a shape="rect" class="external-link" href="http://docs.oracle.com/cd/B13789_01/server.101/b10785/jm_exmpl.htm" rel="nofollow">http://docs.oracle.com/cd/B13789_01/server.101/b10785/jm_exmpl.htm</a></p>
@@ -201,8 +212,8 @@ END;
<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/jms-bridge-with-remote-broker.html
==============================================================================
--- websites/production/activemq/content/jms-bridge-with-remote-broker.html (original)
+++ websites/production/activemq/content/jms-bridge-with-remote-broker.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 ™ -- JMS Bridge With Remote Broker
</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>
@@ -75,37 +86,37 @@
<h3><a shape="rect" name="JMSBridgeWithRemoteBroker-ExampleofaconfigurationthatshowshowtouseaBridgeConnectortomakeaconnectiontoaremoteActiveMQbroker."></a>Example of a configuration that shows how to use a BridgeConnector to make a connection to a remote ActiveMQ broker.</h3>
<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
-<pre class="code-xml">
-<span class="code-tag"><beans></span>
- <span class="code-tag"><span class="code-comment"><!-- Allows us to use system properties as variables in this configuration file --></span></span>
- <span class="code-tag"><bean class=<span class="code-quote">"org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"</span>/></span>
-
- <broker useJmx=<span class="code-quote">"true"</span> persistent=<span class="code-quote">"false"</span> xmlns=<span class="code-quote">"http://activemq.org/config/1.0"</span>
- brokerName=<span class="code-quote">"localhost"</span> dataDirectory=<span class="code-quote">"${activemq.base}/data"</span>>
- <span class="code-tag"><jmsBridgeConnectors></span>
- <span class="code-tag"><jmsQueueConnector outboundQueueConnectionFactory=<span class="code-quote">"#remoteBroker"</span>></span>
- <span class="code-tag"><inboundQueueBridges></span>
+<script class="theme: Default; brush: xml; gutter: false" type="syntaxhighlighter"><![CDATA[
+<beans>
+ <!-- Allows us to use system properties as variables in this configuration file -->
+ <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
+
+ <broker useJmx="true" persistent="false" xmlns="http://activemq.org/config/1.0"
+ brokerName="localhost" dataDirectory="${activemq.base}/data">
+ <jmsBridgeConnectors>
+ <jmsQueueConnector outboundQueueConnectionFactory="#remoteBroker">
+ <inboundQueueBridges>
<inboundQueueBridge
- inboundQueueName = <span class="code-quote">"queue.ping"</span>
- localQueueName = <span class="code-quote">"queue.incomingMsgs.ping"</span>
- selector = <span class="code-quote">"JMSType LIKE 'foo%'"</span>/>
- <span class="code-tag"></inboundQueueBridges></span>
- <span class="code-tag"><outboundQueueBridges></span>
+ inboundQueueName = "queue.ping"
+ localQueueName = "queue.incomingMsgs.ping"
+ selector = "JMSType LIKE 'foo%'"/>
+ </inboundQueueBridges>
+ <outboundQueueBridges>
<outboundQueueBridge
- outboundQueueName = <span class="code-quote">"queue.pong"</span>
- localQueueName = <span class="code-quote">"queue.incomingMsgs.ping"</span>
- selector = <span class="code-quote">"JMSType LIKE 'foo%'"</span>/>
- <span class="code-tag"></outboundQueueBridges></span>
- <span class="code-tag"></jmsQueueConnector></span>
- <span class="code-tag"></jmsBridgeConnectors></span>
- <span class="code-tag"></broker></span>
-
- <span class="code-tag"><span class="code-comment"><!-- JMS ConnectionFactory to use for remote bridging --></span></span>
- <span class="code-tag"><bean id=<span class="code-quote">"remoteBroker"</span> class=<span class="code-quote">"org.apache.activemq.ActiveMQConnectionFactory"</span>></span>
- <span class="code-tag"><property name=<span class="code-quote">"brokerURL"</span> value=<span class="code-quote">"failover:(tcp://remote_activemq:61616)"</span> /></span>
- <span class="code-tag"></bean></span>
-<span class="code-tag"></beans></span>
-</pre>
+ outboundQueueName = "queue.pong"
+ localQueueName = "queue.incomingMsgs.ping"
+ selector = "JMSType LIKE 'foo%'"/>
+ </outboundQueueBridges>
+ </jmsQueueConnector>
+ </jmsBridgeConnectors>
+ </broker>
+
+ <!-- JMS ConnectionFactory to use for remote bridging -->
+ <bean id="remoteBroker" class="org.apache.activemq.ActiveMQConnectionFactory">
+ <property name="brokerURL" value="failover:(tcp://remote_activemq:61616)" />
+ </bean>
+</beans>
+]]></script>
</div></div>
</div>
</td>
@@ -120,8 +131,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/jms-bridge-with-remote-tibco-broker.html
==============================================================================
--- websites/production/activemq/content/jms-bridge-with-remote-tibco-broker.html (original)
+++ websites/production/activemq/content/jms-bridge-with-remote-tibco-broker.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 ™ -- JMS Bridge With Remote TIBCO Broker
</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>
@@ -75,41 +86,41 @@
<h3><a shape="rect" name="JMSBridgeWithRemoteTIBCOBroker-ExampleofaconfigurationthatshowshowtouseaBridgeConnectortomakeaconnectiontoaremoteTIBCOEMSbroker."></a>Example of a configuration that shows how to use a BridgeConnector to make a connection to a remote TIBCO EMS broker.</h3>
<div class="code panel" style="border-width: 1px;"><div class="codeContent panelContent">
-<pre class="code-xml">
-<span class="code-tag"><beans></span>
- <span class="code-tag"><span class="code-comment"><!-- Allows us to use system properties as variables in this configuration file --></span></span>
- <span class="code-tag"><bean class=<span class="code-quote">"org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"</span>/></span>
-
- <broker useJmx=<span class="code-quote">"true"</span> persistent=<span class="code-quote">"false"</span> xmlns=<span class="code-quote">"http://activemq.org/config/1.0"</span>
- brokerName=<span class="code-quote">"localhost"</span> dataDirectory=<span class="code-quote">"${activemq.base}/data"</span>>
-
- <span class="code-tag"><span class="code-comment"><!-- Dependencies: tibjms.jar must be in the activemq lib directory --></span></span>
-
- <span class="code-tag"><span class="code-comment"><!-- bridging definitions for traffic to/from remote activemq instance --></span></span>
- <span class="code-tag"><jmsBridgeConnectors></span>
- <span class="code-tag"><jmsQueueConnector outboundQueueConnectionFactory=<span class="code-quote">"#tibco"</span>></span>
- <span class="code-tag"><inboundQueueBridges></span>
+<script class="theme: Default; brush: xml; gutter: false" type="syntaxhighlighter"><![CDATA[
+<beans>
+ <!-- Allows us to use system properties as variables in this configuration file -->
+ <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
+
+ <broker useJmx="true" persistent="false" xmlns="http://activemq.org/config/1.0"
+ brokerName="localhost" dataDirectory="${activemq.base}/data">
+
+ <!-- Dependencies: tibjms.jar must be in the activemq lib directory -->
+
+ <!-- bridging definitions for traffic to/from remote activemq instance -->
+ <jmsBridgeConnectors>
+ <jmsQueueConnector outboundQueueConnectionFactory="#tibco">
+ <inboundQueueBridges>
<inboundQueueBridge
- inboundQueueName = <span class="code-quote">"queue.ping"</span>
- localQueueName = <span class="code-quote">"queue.incomingMsgs.ping"</span>
- selector = <span class="code-quote">"JMSType LIKE 'foo%'"</span>/>
- <span class="code-tag"></inboundQueueBridges></span>
- <span class="code-tag"><outboundQueueBridges></span>
+ inboundQueueName = "queue.ping"
+ localQueueName = "queue.incomingMsgs.ping"
+ selector = "JMSType LIKE 'foo%'"/>
+ </inboundQueueBridges>
+ <outboundQueueBridges>
<outboundQueueBridge
- outboundQueueName = <span class="code-quote">"queue.pong"</span>
- localQueueName = <span class="code-quote">"queue.incomingMsgs.ping"</span>
- selector = <span class="code-quote">"JMSType LIKE 'foo%'"</span>/>
- <span class="code-tag"></outboundQueueBridges></span>
- <span class="code-tag"></jmsQueueConnector></span>
- <span class="code-tag"></jmsBridgeConnectors></span>
- <span class="code-tag"></broker></span>
-
- <span class="code-tag"><span class="code-comment"><!-- JMS ConnectionFactory to use for local bridging --></span></span>
- <span class="code-tag"><bean id=<span class="code-quote">"tibco"</span> class=<span class="code-quote">"com.tibco.tibjms.TibjmsQueueConnectionFactory"</span>></span>
- <span class="code-tag"><property name=<span class="code-quote">"serverUrl"</span> value=<span class="code-quote">"tcp://remote_tibco:7222"</span> /></span>
- <span class="code-tag"></bean></span>
-<span class="code-tag"></beans></span>
-</pre>
+ outboundQueueName = "queue.pong"
+ localQueueName = "queue.incomingMsgs.ping"
+ selector = "JMSType LIKE 'foo%'"/>
+ </outboundQueueBridges>
+ </jmsQueueConnector>
+ </jmsBridgeConnectors>
+ </broker>
+
+ <!-- JMS ConnectionFactory to use for local bridging -->
+ <bean id="tibco" class="com.tibco.tibjms.TibjmsQueueConnectionFactory">
+ <property name="serverUrl" value="tcp://remote_tibco:7222" />
+ </bean>
+</beans>
+]]></script>
</div></div>
</div>
</td>
@@ -124,8 +135,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/jms-streams.html
==============================================================================
--- websites/production/activemq/content/jms-streams.html (original)
+++ websites/production/activemq/content/jms-streams.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 ™ -- JMS Streams
</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>
@@ -88,30 +98,30 @@
<p>e.g.</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[
ActiveMQConnection connection = ...;
-Destination destination = <span class="code-keyword">new</span> ActiveMQQueue(<span class="code-quote">"FOO.BAR"</span>);
+Destination destination = new ActiveMQQueue("FOO.BAR");
OutputStream out = connection.createOutputStream(destination);
-<span class="code-comment">// write the file to out
-</span>out.close();
-</pre>
+// write the file to out
+out.close();
+]]></script>
</div></div>
<p>Or to consume a large message</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[
ActiveMQConnection connection = ...;
-Destination destination = <span class="code-keyword">new</span> ActiveMQQueue(<span class="code-quote">"FOO.BAR"</span>);
+Destination destination = new ActiveMQQueue("FOO.BAR");
InputStream in = connection.createInputStream(destination)
-<span class="code-comment">// read the stream...
-</span>in.close();
-</pre>
+// read the stream...
+in.close();
+]]></script>
</div></div>
<p>There are overloaded createInputStream/createOutputStream methods which support additional paramateres to be passed.</p>
@@ -139,8 +149,8 @@ The counterpart classes in AMQ 3.x are
<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">