You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by dk...@apache.org on 2017/12/14 14:48:28 UTC
[04/51] [abbrv] [partial] activemq-web git commit: Add body.storage
type
http://git-wip-us.apache.org/repos/asf/activemq-web/blob/7a7d976c/jdbc-support.xml
----------------------------------------------------------------------
diff --git a/jdbc-support.xml b/jdbc-support.xml
index f071449..41ce333 100644
--- a/jdbc-support.xml
+++ b/jdbc-support.xml
@@ -1,32 +1,24 @@
-<div class="wiki-content maincontent"><p>We support a range of SQL databases for message persistence such as</p><ul><li>Apache Derby</li><li>Axion</li><li>DB2</li><li>HSQL</li><li>Informix</li><li>MaxDB</li><li>MySQL</li><li>Oracle</li><li>Postgresql</li><li><a shape="rect" href="sqlserver.xml">SQLServer</a></li><li><a shape="rect" href="sybase.xml">Sybase</a></li></ul><p>as well as a number of generic JDBC providers.</p><h3 id="JDBCSupport-Auto-discoveryofyourJDBCprovider">Auto-discovery of your JDBC provider</h3><p>We try to auto-detect from the JDBC driver which JDBCAdapter to use via these <a shape="rect" class="external-link" href="https://git-wip-us.apache.org/repos/asf?p=activemq.git;a=tree;f=activemq-jdbc-store/src/main/resources/META-INF/services/org/apache/activemq/store/jdbc">config files</a> and the return string from the JDBC driver.</p><p>If you have a JDBC database which we don't support then please let us know what JDBC driver string you're getting and <a shape="rect
" href="discussion-forums.xml">drop us a note</a> or raise an issue in our <a shape="rect" class="external-link" href="http://issues.apache.org/activemq/browse/AMQ">support database</a> and we'll fix it pretty quickly.</p><p>If your database is not in the above list it is normally a matter of tweaking the StatementProvider to ensure that the JDBCMessageStore uses the right flavour of SQL. So normally most databases support one of these providers...</p><ul><li>org.activemq.store.jdbc.adapter.BlobJDBCAdapter</li><li>org.activemq.store.jdbc.adapter.BytesJDBCAdapter</li><li>org.activemq.store.jdbc.adapter.DefaultJDBCAdapter</li><li>org.activemq.store.jdbc.adapter.ImageJDBCAdapter</li></ul><p>You can explicitly specify the JDBC adaptor using its xbean identifier, inside the activemq.xml...</p><div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<script class="brush: java; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[<jdbcPersistenceAdapter adapter="postgresql-jdbc-adapter"/>
-]]></script>
-</div></div><h3 id="JDBCSupport-CustomizingtheSQLDDL">Customizing the SQL DDL</h3><p>You can confiugure the various SQL datatypes - such as column sizes and so forth - using the statements element</p><div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<script class="brush: java; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[ <broker useJmx="false">
+<div class="wiki-content maincontent"><p>We support a range of SQL databases for message persistence such as</p><ul><li>Apache Derby</li><li>Axion</li><li>DB2</li><li>HSQL</li><li>Informix</li><li>MaxDB</li><li>MySQL</li><li>Oracle</li><li>Postgresql</li><li><link><page ri:content-title="SQLServer"></page></link></li><li><link><page ri:content-title="Sybase"></page></link></li></ul><p>as well as a number of generic JDBC providers.</p><h3>Auto-discovery of your JDBC provider</h3><p>We try to auto-detect from the JDBC driver which JDBCAdapter to use via these <a shape="rect" href="https://git-wip-us.apache.org/repos/asf?p=activemq.git;a=tree;f=activemq-jdbc-store/src/main/resources/META-INF/services/org/apache/activemq/store/jdbc">config files</a> and the return string from the JDBC driver.</p><p>If you have a JDBC database which we don't support then please let us know what JDBC driver string you're getting and <link><page ri:content-title="Discussion Forums"></page><plain-text-link-
body>drop us a note</plain-text-link-body></link> or raise an issue in our <a shape="rect" href="http://issues.apache.org/activemq/browse/AMQ">support database</a> and we'll fix it pretty quickly.</p><p>If your database is not in the above list it is normally a matter of tweaking the StatementProvider to ensure that the JDBCMessageStore uses the right flavour of SQL. So normally most databases support one of these providers...</p><ul><li>org.activemq.store.jdbc.adapter.BlobJDBCAdapter</li><li>org.activemq.store.jdbc.adapter.BytesJDBCAdapter</li><li>org.activemq.store.jdbc.adapter.DefaultJDBCAdapter</li><li>org.activemq.store.jdbc.adapter.ImageJDBCAdapter</li></ul><p>You can explicitly specify the JDBC adaptor using its xbean identifier, inside the activemq.xml...</p><structured-macro ac:macro-id="45d22476-142f-4b05-8879-76bd163c8efe" ac:name="code" ac:schema-version="1"><parameter ac:name="">xml</parameter><plain-text-body><jdbcPersistenceAdapter adapter="postgresql-jdbc-adapter"
/>
+</plain-text-body></structured-macro><h3>Customizing the SQL DDL</h3><p>You can confiugure the various SQL datatypes - such as column sizes and so forth - using the statements element</p><structured-macro ac:macro-id="28fb77cc-b99c-46bb-a02a-5bb4f4df4f81" ac:name="code" ac:schema-version="1"><plain-text-body> <broker useJmx="false">
<persistenceAdapter>
- <journaledJDBC useJournal="false">
+ <journaledJDBC useJournal="false">
<statements>
- <statements stringIdDataType ="VARCHAR(128)"/>
+ <statements stringIdDataType ="VARCHAR(128)"/>
</statements>
</journaledJDBC>
</persistenceAdapter>
</broker>
-]]></script>
-</div></div><p>For more info on what attributes can be set on the statements element, see the <a shape="rect" class="external-link" href="http://activemq.apache.org/maven/apidocs/org/apache/activemq/store/jdbc/Statements.html">Statements class</a>. All the settable bean properties can be used as attributes of the <statements> element.</p><h3 id="JDBCSupport-UsingMySQL">Using MySQL</h3><p>If you are using MySQL then you should set the <strong>relaxAutoCommit</strong> flag to be true. e.g.</p><div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<script class="brush: java; gutter: false; theme: Default" 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?relaxAutoCommit=true"/>
- <property name="username" value="activemq"/>
- <property name="password" value="activemq"/>
- <property name="poolPreparedStatements" value="true"/>
+</plain-text-body></structured-macro><p>For more info on what attributes can be set on the statements element, see the <a shape="rect" href="http://activemq.apache.org/maven/apidocs/org/apache/activemq/store/jdbc/Statements.html">Statements class</a>. All the settable bean properties can be used as attributes of the <statements> element.</p><h3>Using MySQL</h3><p>If you are using MySQL then you should set the <strong>relaxAutoCommit</strong> flag to be true. e.g.</p><structured-macro ac:macro-id="150457bb-9c29-40d2-b917-8bca8441f5d7" ac:name="code" ac:schema-version="1"><plain-text-body> <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?relaxAutoCommit=true"/>
+ <property name="username" value="activemq"/>
+ <property name="password" value="activemq"/>
+ <property name="poolPreparedStatements" value="true"/>
</bean>
-]]></script>
-</div></div><p>To see this in action see the <a shape="rect" class="external-link" href="http://svn.apache.org/repos/asf/activemq/trunk/assembly/src/release/conf/activemq.xml">default configuration file</a></p><h3 id="JDBCSupport-ForAMQ3.x">For AMQ 3.x</h3><p>In 3.x you can specify the adapter as follows</p><div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<script class="brush: java; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[<jdbcPersistence adapterClass="org.activemq.store.jdbc.adapter.ImageBasedJDBCAdaptor">
+</plain-text-body></structured-macro><p>To see this in action see the <a shape="rect" href="http://svn.apache.org/repos/asf/activemq/trunk/assembly/src/release/conf/activemq.xml">default configuration file</a></p><h3>For AMQ 3.x</h3><p>In 3.x you can specify the adapter as follows</p><structured-macro ac:macro-id="8a41d054-c2d5-4b21-84f7-c430ace0b29c" ac:name="code" ac:schema-version="1"><parameter ac:name="">xml</parameter><plain-text-body><jdbcPersistence adapterClass="org.activemq.store.jdbc.adapter.ImageBasedJDBCAdaptor">
...
</jdbcPersistence>
-]]></script>
-</div></div></div>
+</plain-text-body></structured-macro></div>
http://git-wip-us.apache.org/repos/asf/activemq-web/blob/7a7d976c/jmeter-performance-tests.xml
----------------------------------------------------------------------
diff --git a/jmeter-performance-tests.xml b/jmeter-performance-tests.xml
index c316dc8..aed4dcf 100644
--- a/jmeter-performance-tests.xml
+++ b/jmeter-performance-tests.xml
@@ -1,17 +1,17 @@
-<div class="wiki-content maincontent"><h3 id="JMeterPerformanceTests-JMeterperformancetest">JMeter performance test</h3>
+<div class="wiki-content maincontent"><h3>JMeter performance test</h3>
-<p>You can use JMeter to test the performance of your ActiveMQ Server. Please refer to the <a shape="rect" class="external-link" href="http://jakarta.apache.org/jmeter/">JMeter site</a> for detailed instructions on using this software.</p>
+<p>You can use JMeter to test the performance of your ActiveMQ Server. Please refer to the <a shape="rect" href="http://jakarta.apache.org/jmeter/">JMeter site</a> for detailed instructions on using this software.</p>
-<h3 id="JMeterPerformanceTests-DownloadingtheJMeterPerformanceTestBinary">Downloading the JMeter Performance Test Binary</h3>
+<h3>Downloading the JMeter Performance Test Binary</h3>
<p>You can download the latest activemq-jmeter-*.zip distribution from the following</p>
-<ul><li><a shape="rect" class="external-link" href="http://people.apache.org/repository/incubator-activemq/distributions/">Apache ActiveMQ versions</a></li><li><a shape="rect" class="external-link" href="http://dist.codehaus.org/activemq/distributions/" rel="nofollow">3.x versions of ActiveMQ</a>.</li></ul>
+<ul><li><a shape="rect" href="http://people.apache.org/repository/incubator-activemq/distributions/">Apache ActiveMQ versions</a></li><li><a shape="rect" href="http://dist.codehaus.org/activemq/distributions/">3.x versions of ActiveMQ</a>.</li></ul>
-<h3 id="JMeterPerformanceTests-BuildingtheJMeterPerformanceTestfromsource">Building the JMeter Performance Test from source</h3>
+<h3>Building the JMeter Performance Test from source</h3>
-<p>1. Check out the latest head version of ActiveMQ from <a shape="rect" href="source.xml">Source</a>. Build from source.</p>
+<p>1. Check out the latest head version of ActiveMQ from <link><page ri:content-title="Source"></page></link>. Build from source.</p>
<p>2. Run maven from the JMeter directory. This will build JMeter into the target directory.</p>
@@ -19,7 +19,7 @@
<p>4. There are sample Test Plans located at \bin\testfiles directory that you could open to test ActiveMQ.</p>
-<h3 id="JMeterPerformanceTests-BuildingaTestPlan">Building a Test Plan</h3>
+<h3>Building a Test Plan</h3>
<p>For a Producer Sampler<br clear="none">
1. Add a Thread Group.<br clear="none">
@@ -33,7 +33,7 @@
3. Highlight the Consumer Sampler then right click to add the consumer listener "View Consumer Results" from the Listener menu.<br clear="none">
4. Go to the Thread Group element and set the Number of Threads, Ramp-Up Period and Loop Count to 1.</p>
-<h3 id="JMeterPerformanceTests-TheJMeterPerformanceTestModuleconsistsof:">The JMeter Performance Test Module consists of:</h3>
+<h3>The JMeter Performance Test Module consists of:</h3>
<p>1. JMeter Producer Sampler</p>
<ul class="alternate"><li>A JMeter Sampler tells JMeter to send requests to the server. Pluggable Samplers allow unlimited testing capabilities.</li></ul>
@@ -57,5 +57,6 @@
<p>4. JMeter Consumer Listener</p>
-<ul class="alternate"><li>The Consumer Listener would provide statistics with the number of messages received and average messages per second.</li></ul></div>
+<ul class="alternate"><li>The Consumer Listener would provide statistics with the number of messages received and average messages per second.</li></ul>
+</div>
http://git-wip-us.apache.org/repos/asf/activemq-web/blob/7a7d976c/jmeter-system-tests.xml
----------------------------------------------------------------------
diff --git a/jmeter-system-tests.xml b/jmeter-system-tests.xml
index a3c62cc..275ac22 100644
--- a/jmeter-system-tests.xml
+++ b/jmeter-system-tests.xml
@@ -1,10 +1,10 @@
<div class="wiki-content maincontent">
-<h3 id="JMeterSystemTests-JMeterSystemTests">JMeter System Tests</h3>
+<h3>JMeter System Tests</h3>
<p>You can use JMeter to test your ActiveMQ Server. Please refer to the JMeter site for detailed instructions on using this software.<br clear="none">
The Test would check for duplicate messages and the order of messages received.</p>
-<h3 id="JMeterSystemTests-BuildingaTestPlan">Building a Test Plan</h3>
+<h3>Building a Test Plan</h3>
<p>For a Producer System Test Sampler<br clear="none">
1. Add a Thread Group.<br clear="none">
@@ -16,7 +16,7 @@ The Test would check for duplicate messages and the order of messages received.<
2. Highlight te Consumer Sampler then right click to add the consumer listener "View Producer System Test Results" from the Listener menu.</p>
-<h3 id="JMeterSystemTests-TheJMeterSystemTestModuleisconsistof:">The JMeter System Test Module is consist of:</h3>
+<h3>The JMeter System Test Module is consist of:</h3>
<p>1. JMeter Producer System Test Sampler</p>
<ul class="alternate"><li>A JMeter Sampler tells JMeter to send requests to the server. Pluggable Samplers allow unlimited testing capabilities.</li></ul>
@@ -46,5 +46,6 @@ The Test would check for duplicate messages and the order of messages received.<
<ul class="alternate"><li>Consumer Identifier - Identifies the Consumer that received the message.</li><li>Producer Name - Producer name that send the message.</li><li>Message - The message body received.</li><li>Message Count - The number of messages received.</li></ul>
+
</div>
http://git-wip-us.apache.org/repos/asf/activemq-web/blob/7a7d976c/jms-and-jdbc-operations-in-one-transaction.xml
----------------------------------------------------------------------
diff --git a/jms-and-jdbc-operations-in-one-transaction.xml b/jms-and-jdbc-operations-in-one-transaction.xml
index e2a3b3f..80fcaa0 100644
--- a/jms-and-jdbc-operations-in-one-transaction.xml
+++ b/jms-and-jdbc-operations-in-one-transaction.xml
@@ -1,13 +1,12 @@
-<div class="wiki-content maincontent"><h3 id="JMSandJDBCoperationsinonetransaction-JMSandJDBCoperationsinonetransactionwithSpring/Jencks/ActiveMQ">JMS and JDBC operations in one transaction with Spring/Jencks/ActiveMQ</h3>
+<div class="wiki-content maincontent"><h3>JMS and JDBC operations in one transaction with Spring/Jencks/ActiveMQ</h3>
<p>Spring beans:</p>
-<div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<script class="brush: java; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[
+<structured-macro ac:macro-id="131960d2-7879-4564-9ec8-932ad251d58d" ac:name="code" ac:schema-version="1"><parameter ac:name="">xml</parameter><plain-text-body>
<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">
+ <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>
@@ -15,111 +14,109 @@
</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 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 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"/>
+ <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">
+ <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 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 id="jmsConnectionFactory" class="org.springframework.jca.support.LocalConnectionFactoryBean">
+ <property name="managedConnectionFactory" ref="jmsManagedConnectionFactory"/>
+ <property name="connectionManager" ref="connectionManager"/>
</bean>
<!-- Tranql JDBC Connection -->
<!--
- <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 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 id="tranqlDataSource" class="org.springframework.jca.support.LocalConnectionFactoryBean">
+ <property name="managedConnectionFactory" ref="tranqlManagedConnectionFactory"/>
+ <property name="connectionManager" ref="connectionManager"/>
</bean>
-->
<!-- 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 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"/>
+ <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 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"/>
+ <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 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"/>
+ <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 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"/>
+ <property name="jmsTemplate">
+ <bean class="org.springframework.jms.core.JmsTemplate">
+ <property name="connectionFactory" ref="jmsConnectionFactory"/>
</bean>
</property>
</bean>
</beans>
-]]></script>
-</div></div>
+</plain-text-body></structured-macro>
<p>Java code:</p>
-<div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<script class="brush: java; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[
+<structured-macro ac:macro-id="cfe63126-2a2e-4b7b-8771-2ba6ff05ea6a" ac:name="code" ac:schema-version="1"><parameter ac:name="">java</parameter><plain-text-body>
public class EchoBean implements MessageListener {
private Log log = LogFactory.getLog(getClass());
@@ -140,16 +137,15 @@ public class EchoBean implements MessageListener {
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+"')");
+ 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();
}
}
}
}
-]]></script>
-</div></div></div>
+</plain-text-body></structured-macro></div>
http://git-wip-us.apache.org/repos/asf/activemq-web/blob/7a7d976c/jms-bridge-with-local-broker.xml
----------------------------------------------------------------------
diff --git a/jms-bridge-with-local-broker.xml b/jms-bridge-with-local-broker.xml
index 425e740..a3a6b3e 100644
--- a/jms-bridge-with-local-broker.xml
+++ b/jms-bridge-with-local-broker.xml
@@ -1,36 +1,34 @@
-<div class="wiki-content maincontent"><h3 id="JMSBridgeWithLocalBroker-ExampleofaconfigurationthatshowshowtouseaBridgeConnectortomakeaconnectiontothelocalActiveMQbroker.">Example of a configuration that shows how to use a BridgeConnector to make a connection to the local ActiveMQ broker.</h3>
+<div class="wiki-content maincontent"><h3>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 pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<script class="brush: java; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[
+<structured-macro ac:macro-id="4e5f3026-cbef-453b-ba5f-9746421eaa2d" ac:name="code" ac:schema-version="1"><parameter ac:name="">xml</parameter><plain-text-body>
<beans>
<!-- Allows us to use system properties as variables in this configuration file -->
- <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
+ <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 useJmx="true" persistent="false" xmlns="http://activemq.org/config/1.0"
+ brokerName="localhost" dataDirectory="${activemq.base}/data">
<jmsBridgeConnectors>
- <jmsQueueConnector outboundQueueConnectionFactory="#localBroker">
+ <jmsQueueConnector outboundQueueConnectionFactory="#localBroker">
<inboundQueueBridges>
<inboundQueueBridge
- inboundQueueName = "queue.ping"
- localQueueName = "queue.incomingMsgs.ping"
- selector = "JMSType LIKE 'foo%'"/>
+ inboundQueueName = "queue.ping"
+ localQueueName = "queue.incomingMsgs.ping"
+ selector = "JMSType LIKE 'foo%'"/>
</inboundQueueBridges>
<outboundQueueBridges>
<outboundQueueBridge
- localQueueName = "queue.incomingMsgs.ping"
- outboundQueueName = "queue.pong"
- selector = "JMSType LIKE 'foo%'"/>
+ 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 id="localBroker" class="org.apache.activemq.ActiveMQConnectionFactory">
+ <property name="brokerURL" value="vm://localhost:61616" />
</bean>
</beans>
-]]></script>
-</div></div></div>
+</plain-text-body></structured-macro></div>
http://git-wip-us.apache.org/repos/asf/activemq-web/blob/7a7d976c/jms-bridge-with-oracle-aq.xml
----------------------------------------------------------------------
diff --git a/jms-bridge-with-oracle-aq.xml b/jms-bridge-with-oracle-aq.xml
index ff89c94..5aab871 100644
--- a/jms-bridge-with-oracle-aq.xml
+++ b/jms-bridge-with-oracle-aq.xml
@@ -1,117 +1,113 @@
-<div class="wiki-content maincontent"><h3 id="JMSBridgeWithOracleAQ-ExampleofaconfigurationthatshowshowtoconnecttoOracleAQqueuesandtopics.">Example of a configuration that shows how to connect to Oracle AQ queues and topics.</h3>
+<div class="wiki-content maincontent"><h3>Example of a configuration that shows how to connect to Oracle AQ queues and topics.</h3>
-<div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<script class="brush: java; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[
+<structured-macro ac:macro-id="4cf21870-0ab2-4f52-a906-fabf122f573a" ac:name="code" ac:schema-version="1"><parameter ac:name="">xml</parameter><plain-text-body>
<beans>
<!-- Allows us to use system properties as variables in this configuration file -->
- <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
+ <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 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">
+ <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" >
+ <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" >
+ <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">
+ <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">
+ <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="requiredBeanForOracleAq" class="org.apache.activemq.ActiveMQConnectionFactory" />
- <bean id="connectionFactoryOracleAQQueue" class="oracle.jms.AQjmsFactory" factory-method="getQueueConnectionFactory">
- <constructor-arg index="0">
+ <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">
+ <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">
+ <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">
+ <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">
+ <bean id="oracleQueueCredentials" class="org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter">
+ <property name="targetConnectionFactory">
+ <ref bean="connectionFactoryOracleAQQueue">
</property>
- <property name="username">
+ <property name="username">
<value>foo</value>
</property>
- <property name="password">
+ <property name="password">
<value>bar</value>
</property>
</bean>
- <bean id="oracleTopicCredentials" class="org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter">
- <property name="targetConnectionFactory">
- <ref bean="connectionFactoryOracleAQTopic">
+ <bean id="oracleTopicCredentials" class="org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter">
+ <property name="targetConnectionFactory">
+ <ref bean="connectionFactoryOracleAQTopic">
</property>
- <property name="username">
+ <property name="username">
<value>foo</value>
</property>
- <property name="password">
+ <property name="password">
<value>bar</value>
</property>
</bean>
- <bean id="oracleQueue" class="org.apache.camel.component.jms.JmsComponent">
- <property name="connectionFactory" ref="oracleQueueCredentials">
+ <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 id="oracleTopic" class="org.apache.camel.component.jms.JmsComponent">
+ <property name="connectionFactory" ref="oracleTopicCredentials">
</bean>
</beans>
-]]></script>
-</div></div>
+</plain-text-body></structured-macro>
-<p>If you run in an OSGi environment such as <a shape="rect" class="external-link" href="http://servicemix.apache.org">ServiceMix 4</a> then take a look at <a shape="rect" class="external-link" href="http://servicemix.396122.n5.nabble.com/ServiceMix-4-2-Camel-OracleAQ-td421214.html#a421214" rel="nofollow">this discussion</a> how to install the OracleAQ Client in the OSGi container.</p>
+<p>If you run in an OSGi environment such as <a shape="rect" href="http://servicemix.apache.org">ServiceMix 4</a> then take a look at <a shape="rect" href="http://servicemix.396122.n5.nabble.com/ServiceMix-4-2-Camel-OracleAQ-td421214.html#a421214">this discussion</a> how to install the OracleAQ Client in the OSGi container.</p>
-<h4 id="JMSBridgeWithOracleAQ-OracleSQLcode">Oracle SQL code</h4>
+<h4>Oracle SQL code</h4>
<p>You may need to setup OracleAQ, and here is a sample code</p>
-<div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<script class="brush: java; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[
+<structured-macro ac:macro-id="efdb1a06-1164-41a6-86ee-ce8b6fc792b7" ac:name="code" ac:schema-version="1"><plain-text-body>
BEGIN
- DBMS_AQADM.CREATE_QUEUE_TABLE( queue_table => 'queue_message_table', queue_payload_type => 'SYS.AQ$_JMS_TEXT_MESSAGE');
+ DBMS_AQADM.CREATE_QUEUE_TABLE( queue_table => 'queue_message_table', queue_payload_type => 'SYS.AQ$_JMS_TEXT_MESSAGE');
END;
BEGIN
- DBMS_AQADM.CREATE_QUEUE( queue_name => 'ORACLE_QUEUE', queue_table => 'queue_message_table');
+ DBMS_AQADM.CREATE_QUEUE( queue_name => 'ORACLE_QUEUE', queue_table => 'queue_message_table');
END;
BEGIN
- DBMS_AQADM.START_QUEUE(queue_name => 'ORACLE_QUEUE');
+ DBMS_AQADM.START_QUEUE(queue_name => 'ORACLE_QUEUE');
END;
-]]></script>
-</div></div>
+</plain-text-body></structured-macro>
-<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></div>
+<p>You can also find more information about OracleAQ and using JMS at: <a shape="rect" href="http://docs.oracle.com/cd/B13789_01/server.101/b10785/jm_exmpl.htm">http://docs.oracle.com/cd/B13789_01/server.101/b10785/jm_exmpl.htm</a></p></div>
http://git-wip-us.apache.org/repos/asf/activemq-web/blob/7a7d976c/jms-bridge-with-remote-broker.xml
----------------------------------------------------------------------
diff --git a/jms-bridge-with-remote-broker.xml b/jms-bridge-with-remote-broker.xml
index 8294efd..7551833 100644
--- a/jms-bridge-with-remote-broker.xml
+++ b/jms-bridge-with-remote-broker.xml
@@ -1,36 +1,34 @@
-<div class="wiki-content maincontent"><h3 id="JMSBridgeWithRemoteBroker-ExampleofaconfigurationthatshowshowtouseaBridgeConnectortomakeaconnectiontoaremoteActiveMQbroker.">Example of a configuration that shows how to use a BridgeConnector to make a connection to a remote ActiveMQ broker.</h3>
+<div class="wiki-content maincontent"><h3>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 pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<script class="brush: java; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[
+<structured-macro ac:macro-id="841c501d-dd07-4c45-9354-bdbcb93ff0cc" ac:name="code" ac:schema-version="1"><parameter ac:name="">xml</parameter><plain-text-body>
<beans>
<!-- Allows us to use system properties as variables in this configuration file -->
- <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
+ <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 useJmx="true" persistent="false" xmlns="http://activemq.org/config/1.0"
+ brokerName="localhost" dataDirectory="${activemq.base}/data">
<jmsBridgeConnectors>
- <jmsQueueConnector outboundQueueConnectionFactory="#remoteBroker">
+ <jmsQueueConnector outboundQueueConnectionFactory="#remoteBroker">
<inboundQueueBridges>
<inboundQueueBridge
- inboundQueueName = "queue.ping"
- localQueueName = "queue.incomingMsgs.ping"
- selector = "JMSType LIKE 'foo%'"/>
+ inboundQueueName = "queue.ping"
+ localQueueName = "queue.incomingMsgs.ping"
+ selector = "JMSType LIKE 'foo%'"/>
</inboundQueueBridges>
<outboundQueueBridges>
<outboundQueueBridge
- outboundQueueName = "queue.pong"
- localQueueName = "queue.incomingMsgs.ping"
- selector = "JMSType LIKE 'foo%'"/>
+ 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 id="remoteBroker" class="org.apache.activemq.ActiveMQConnectionFactory">
+ <property name="brokerURL" value="failover:(tcp://remote_activemq:61616)" />
</bean>
</beans>
-]]></script>
-</div></div></div>
+</plain-text-body></structured-macro></div>
http://git-wip-us.apache.org/repos/asf/activemq-web/blob/7a7d976c/jms-bridge-with-remote-tibco-broker.xml
----------------------------------------------------------------------
diff --git a/jms-bridge-with-remote-tibco-broker.xml b/jms-bridge-with-remote-tibco-broker.xml
index 726a494..0cd5a71 100644
--- a/jms-bridge-with-remote-tibco-broker.xml
+++ b/jms-bridge-with-remote-tibco-broker.xml
@@ -1,40 +1,38 @@
-<div class="wiki-content maincontent"><h3 id="JMSBridgeWithRemoteTIBCOBroker-ExampleofaconfigurationthatshowshowtouseaBridgeConnectortomakeaconnectiontoaremoteTIBCOEMSbroker.">Example of a configuration that shows how to use a BridgeConnector to make a connection to a remote TIBCO EMS broker.</h3>
+<div class="wiki-content maincontent"><h3>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 pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<script class="brush: java; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[
+<structured-macro ac:macro-id="77975890-00a2-41e6-9b62-df2e59352b0e" ac:name="code" ac:schema-version="1"><parameter ac:name="">xml</parameter><plain-text-body>
<beans>
<!-- Allows us to use system properties as variables in this configuration file -->
- <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
+ <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 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">
+ <jmsQueueConnector outboundQueueConnectionFactory="#tibco">
<inboundQueueBridges>
<inboundQueueBridge
- inboundQueueName = "queue.ping"
- localQueueName = "queue.incomingMsgs.ping"
- selector = "JMSType LIKE 'foo%'"/>
+ inboundQueueName = "queue.ping"
+ localQueueName = "queue.incomingMsgs.ping"
+ selector = "JMSType LIKE 'foo%'"/>
</inboundQueueBridges>
<outboundQueueBridges>
<outboundQueueBridge
- outboundQueueName = "queue.pong"
- localQueueName = "queue.incomingMsgs.ping"
- selector = "JMSType LIKE 'foo%'"/>
+ 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 id="tibco" class="com.tibco.tibjms.TibjmsQueueConnectionFactory">
+ <property name="serverUrl" value="tcp://remote_tibco:7222" />
</bean>
</beans>
-]]></script>
-</div></div></div>
+</plain-text-body></structured-macro></div>
http://git-wip-us.apache.org/repos/asf/activemq-web/blob/7a7d976c/jms-streams.xml
----------------------------------------------------------------------
diff --git a/jms-streams.xml b/jms-streams.xml
index e75c722..47dd537 100644
--- a/jms-streams.xml
+++ b/jms-streams.xml
@@ -1,60 +1,57 @@
<div class="wiki-content maincontent"><p><strong>deprecated</strong></p>
-<div class="confluence-information-macro confluence-information-macro-warning"><span class="aui-icon aui-icon-small aui-iconfont-error confluence-information-macro-icon"></span><div class="confluence-information-macro-body">
-<p>This feature is deprecated, and end users is encouraged to <strong>not</strong> use it. This feature will be removed in a later ActiveMQ release.</p></div></div>
+<structured-macro ac:macro-id="88cf66c6-a3ba-4c16-afbf-0ef5c8fed79a" ac:name="warning" ac:schema-version="1"><rich-text-body>
+<p>This feature is deprecated, and end users is encouraged to <strong>not</strong> use it. This feature will be removed in a later ActiveMQ release.</p></rich-text-body></structured-macro>
<p>Sometimes you need to send truly massive files (many Gb) around the network in a reliable manner. The JMS API expects JMS clients to be able to keep a message in memory at one time, so sending > 1Gb messages around ends up using way too much RAM on the client side.</p>
-<p>To solve this problem ActiveMQ supports regular <a shape="rect" class="external-link" href="http://java.sun.com/j2se/1.4.2/docs/api/java/io/InputStream.html" rel="nofollow">InputStream</a> and <a shape="rect" class="external-link" href="http://java.sun.com/j2se/1.4.2/docs/api/java/io/OutputStream.html" rel="nofollow">OutputStream</a> abstractions which work with regular JMS producers and consumers.</p>
+<p>To solve this problem ActiveMQ supports regular <a shape="rect" href="http://java.sun.com/j2se/1.4.2/docs/api/java/io/InputStream.html">InputStream</a> and <a shape="rect" href="http://java.sun.com/j2se/1.4.2/docs/api/java/io/OutputStream.html">OutputStream</a> abstractions which work with regular JMS producers and consumers.</p>
-<p>This allows you to use the familar streams from Java to send or receive messages of any size at all (providing your file system can handle them <img class="emoticon emoticon-smile" src="https://cwiki.apache.org/confluence/s/en_GB/5997/6f42626d00e36f53fe51440403446ca61552e2a2.1/_/images/icons/emoticons/smile.png" data-emoticon-name="smile" alt="(smile)"> while keeping a low memory overhead.</p>
+<p>This allows you to use the familar streams from Java to send or receive messages of any size at all (providing your file system can handle them <emoticon ac:name="smile"></emoticon> while keeping a low memory overhead.</p>
-<div class="confluence-information-macro confluence-information-macro-information"><p class="title">For Users of 4.2</p><span class="aui-icon aui-icon-small aui-iconfont-info confluence-information-macro-icon"></span><div class="confluence-information-macro-body">
-<p>If you are using 4.2 onwards of ActiveMQ we highly recommend you try out <a shape="rect" href="blob-messages.xml">Blob Messages</a> which offers a more flexible mechanism for dealing wtih massive files and fully supports out-of-band transfer using HTTP/FTP as well as allowing external resources to be sent around the JMS network.</p></div></div>
+<structured-macro ac:macro-id="3849c84e-3152-47d0-8075-de533a4015af" ac:name="info" ac:schema-version="1"><parameter ac:name="title">For Users of 4.2</parameter><rich-text-body>
+<p>If you are using 4.2 onwards of ActiveMQ we highly recommend you try out <link><page ri:content-title="Blob Messages"></page></link> which offers a more flexible mechanism for dealing wtih massive files and fully supports out-of-band transfer using HTTP/FTP as well as allowing external resources to be sent around the JMS network.</p></rich-text-body></structured-macro>
-<h3 id="JMSStreams-UsingJMSStreams">Using JMS Streams</h3>
+<h3>Using JMS Streams</h3>
-<p>To use the streams just create an input or output stream depending on if you are reading or writing using the <a shape="rect" class="external-link" href="http://incubator.apache.org/activemq/maven/activemq-core/apidocs/org/apache/activemq/ActiveMQConnection.html#createInputStream(javax.jms.Destination)">connection.createInputStream()</a> or<br clear="none">
-<a shape="rect" class="external-link" href="http://incubator.apache.org/activemq/maven/activemq-core/apidocs/org/apache/activemq/ActiveMQConnection.html#createOutputStream(javax.jms.Destination)">connection.createOutputStream()</a> methods.</p>
+<p>To use the streams just create an input or output stream depending on if you are reading or writing using the <a shape="rect" href="http://incubator.apache.org/activemq/maven/activemq-core/apidocs/org/apache/activemq/ActiveMQConnection.html#createInputStream(javax.jms.Destination)">connection.createInputStream()</a> or<br clear="none">
+<a shape="rect" href="http://incubator.apache.org/activemq/maven/activemq-core/apidocs/org/apache/activemq/ActiveMQConnection.html#createOutputStream(javax.jms.Destination)">connection.createOutputStream()</a> methods.</p>
<p>e.g.</p>
-<div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<script class="brush: java; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[
+<structured-macro ac:macro-id="0a3d4912-0a8c-4072-8031-2972c28d04ab" ac:name="code" ac:schema-version="1"><plain-text-body>
ActiveMQConnection connection = ...;
-Destination destination = new ActiveMQQueue("FOO.BAR");
+Destination destination = new ActiveMQQueue("FOO.BAR");
OutputStream out = connection.createOutputStream(destination);
// write the file to out
out.close();
-]]></script>
-</div></div>
+</plain-text-body></structured-macro>
<p>Or to consume a large message</p>
-<div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
-<script class="brush: java; gutter: false; theme: Default" type="syntaxhighlighter"><![CDATA[
+<structured-macro ac:macro-id="e351d85f-34c6-4d59-b017-d9489e64f04f" ac:name="code" ac:schema-version="1"><plain-text-body>
ActiveMQConnection connection = ...;
-Destination destination = new ActiveMQQueue("FOO.BAR");
+Destination destination = new ActiveMQQueue("FOO.BAR");
InputStream in = connection.createInputStream(destination)
// read the stream...
in.close();
-]]></script>
-</div></div>
+</plain-text-body></structured-macro>
<p>There are overloaded createInputStream/createOutputStream methods which support additional paramateres to be passed.</p>
<p>For further reference see the javadoc.</p>
-<ul><li><a shape="rect" class="external-link" href="http://activemq.apache.org/maven/activemq-core/apidocs/org/apache/activemq/ActiveMQInputStream.html">ActiveMQInputStream </a></li><li><a shape="rect" class="external-link" href="http://activemq.apache.org/maven/activemq-core/apidocs/org/apache/activemq/ActiveMQOutputStream.html">ActiveMQOutputStream </a></li></ul>
+<ul><li><a shape="rect" href="http://activemq.apache.org/maven/activemq-core/apidocs/org/apache/activemq/ActiveMQInputStream.html">ActiveMQInputStream </a></li><li><a shape="rect" href="http://activemq.apache.org/maven/activemq-core/apidocs/org/apache/activemq/ActiveMQOutputStream.html">ActiveMQOutputStream </a></li></ul>
<p><em>Note:</em><br clear="none">
The counterpart classes in AMQ 3.x are :</p>
-<ul><li>JMSInputStream</li><li>JMSOutputStream</li></ul></div>
+<ul><li>JMSInputStream</li><li>JMSOutputStream</li></ul>
+</div>