[hornetq-commits] JBoss hornetq SVN: r7810 - in trunk: examples/javaee/ejb-jms-transaction and 254 other directories.

Author: clebert.suconic(a)jboss.com Date: 2009-08-19 19:59:53 -0400 (Wed, 19 Aug 2009) New Revision: 7810 Added: trunk/examples/javaee/ejb-jms-transaction/src/org/hornetq/ trunk/examples/javaee/ejb-jms-transaction/src/org/hornetq/javaee/ trunk/examples/javaee/ejb-jms-transaction/src/org/hornetq/javaee/example/ trunk/examples/javaee/ejb-jms-transaction/src/org/hornetq/javaee/example/EJBClientExample.java trunk/examples/javaee/ejb-jms-transaction/src/org/hornetq/javaee/example/server/ trunk/examples/javaee/hajndi/src/org/hornetq/ trunk/examples/javaee/hajndi/src/org/hornetq/javaee/ trunk/examples/javaee/hajndi/src/org/hornetq/javaee/example/ trunk/examples/javaee/jms-bridge/src/org/hornetq/ trunk/examples/javaee/jms-bridge/src/org/hornetq/javaee/ trunk/examples/javaee/jms-bridge/src/org/hornetq/javaee/example/ trunk/examples/javaee/mdb-bmt/src/org/hornetq/ trunk/examples/javaee/mdb-bmt/src/org/hornetq/javaee/ trunk/examples/javaee/mdb-bmt/src/org/hornetq/javaee/example/ trunk/examples/javaee/mdb-bmt/src/org/hornetq/javaee/example/MDB_BMTClientExample.java trunk/examples/javaee/mdb-bmt/src/org/hornetq/javaee/example/server/ trunk/examples/javaee/mdb-cmt-setrollbackonly/src/org/hornetq/ trunk/examples/javaee/mdb-cmt-setrollbackonly/src/org/hornetq/javaee/ trunk/examples/javaee/mdb-cmt-setrollbackonly/src/org/hornetq/javaee/example/ trunk/examples/javaee/mdb-cmt-setrollbackonly/src/org/hornetq/javaee/example/MDB_CMT_SetRollbackOnlyClientExample.java trunk/examples/javaee/mdb-cmt-setrollbackonly/src/org/hornetq/javaee/example/server/ trunk/examples/javaee/mdb-cmt-tx-local/src/org/hornetq/ trunk/examples/javaee/mdb-cmt-tx-local/src/org/hornetq/javaee/ trunk/examples/javaee/mdb-cmt-tx-local/src/org/hornetq/javaee/example/ trunk/examples/javaee/mdb-cmt-tx-local/src/org/hornetq/javaee/example/MDB_CMT_TxLocalClientExample.java trunk/examples/javaee/mdb-cmt-tx-local/src/org/hornetq/javaee/example/server/ trunk/examples/javaee/mdb-cmt-tx-not-supported/src/org/hornetq/ trunk/examples/javaee/mdb-cmt-tx-not-supported/src/org/hornetq/javaee/ trunk/examples/javaee/mdb-cmt-tx-not-supported/src/org/hornetq/javaee/example/ trunk/examples/javaee/mdb-cmt-tx-not-supported/src/org/hornetq/javaee/example/MDB_CMT_TxNotSupportedClientExample.java trunk/examples/javaee/mdb-cmt-tx-not-supported/src/org/hornetq/javaee/example/server/ trunk/examples/javaee/mdb-cmt-tx-required/src/org/hornetq/ trunk/examples/javaee/mdb-cmt-tx-required/src/org/hornetq/javaee/ trunk/examples/javaee/mdb-cmt-tx-required/src/org/hornetq/javaee/example/ trunk/examples/javaee/mdb-cmt-tx-required/src/org/hornetq/javaee/example/MDB_CMT_TxRequiredClientExample.java trunk/examples/javaee/mdb-cmt-tx-required/src/org/hornetq/javaee/example/server/ trunk/examples/javaee/servlet-ssl-example/src/org/hornetq/ trunk/examples/javaee/servlet-ssl-example/src/org/hornetq/javaee/ trunk/examples/javaee/servlet-ssl-example/src/org/hornetq/javaee/example/ trunk/examples/javaee/servlet-transport/src/org/hornetq/ trunk/examples/javaee/servlet-transport/src/org/hornetq/javaee/ trunk/examples/javaee/servlet-transport/src/org/hornetq/javaee/example/ trunk/examples/javaee/xarecovery/src/org/hornetq/ trunk/examples/javaee/xarecovery/src/org/hornetq/javaee/ trunk/examples/javaee/xarecovery/src/org/hornetq/javaee/example/ trunk/examples/javaee/xarecovery/src/org/hornetq/javaee/example/XARecoveryExample.java trunk/examples/javaee/xarecovery/src/org/hornetq/javaee/example/server/ trunk/examples/jms/management-notifications/src/org/hornetq/ trunk/examples/jms/management-notifications/src/org/hornetq/jms/ trunk/examples/jms/management-notifications/src/org/hornetq/jms/example/ trunk/examples/jms/management/src/org/hornetq/ trunk/examples/jms/management/src/org/hornetq/jms/ trunk/examples/jms/management/src/org/hornetq/jms/example/ trunk/examples/jms/message-counters/src/org/hornetq/ trunk/examples/jms/message-counters/src/org/hornetq/jms/ trunk/examples/jms/message-counters/src/org/hornetq/jms/example/ trunk/examples/jms/message-group/src/org/hornetq/ trunk/examples/jms/message-group/src/org/hornetq/jms/ trunk/examples/jms/message-group/src/org/hornetq/jms/example/ trunk/examples/jms/message-priority/src/org/hornetq/ trunk/examples/jms/message-priority/src/org/hornetq/jms/ trunk/examples/jms/message-priority/src/org/hornetq/jms/example/ trunk/examples/jms/no-consumer-buffering/src/org/hornetq/ trunk/examples/jms/no-consumer-buffering/src/org/hornetq/jms/ trunk/examples/jms/no-consumer-buffering/src/org/hornetq/jms/example/ trunk/examples/jms/paging/src/org/hornetq/ trunk/examples/jms/paging/src/org/hornetq/jms/ trunk/examples/jms/paging/src/org/hornetq/jms/example/ trunk/examples/jms/perf/src/org/hornetq/ trunk/examples/jms/perf/src/org/hornetq/jms/ trunk/examples/jms/perf/src/org/hornetq/jms/example/ trunk/examples/jms/pre-acknowledge/src/org/hornetq/ trunk/examples/jms/pre-acknowledge/src/org/hornetq/jms/ trunk/examples/jms/pre-acknowledge/src/org/hornetq/jms/example/ trunk/examples/jms/producer-rate-limit/src/org/hornetq/ trunk/examples/jms/producer-rate-limit/src/org/hornetq/jms/ trunk/examples/jms/producer-rate-limit/src/org/hornetq/jms/example/ trunk/examples/jms/queue-message-redistribution/src/org/hornetq/ trunk/examples/jms/queue-message-redistribution/src/org/hornetq/jms/ trunk/examples/jms/queue-message-redistribution/src/org/hornetq/jms/example/ trunk/examples/jms/queue-requestor/src/org/hornetq/ trunk/examples/jms/queue-requestor/src/org/hornetq/jms/ trunk/examples/jms/queue-requestor/src/org/hornetq/jms/example/ trunk/examples/jms/queue-selector/src/org/hornetq/ trunk/examples/jms/queue-selector/src/org/hornetq/jms/ trunk/examples/jms/queue-selector/src/org/hornetq/jms/example/ trunk/examples/jms/queue/src/org/hornetq/ trunk/examples/jms/queue/src/org/hornetq/jms/ trunk/examples/jms/queue/src/org/hornetq/jms/example/ trunk/examples/jms/reconnect-same-node/src/org/hornetq/ trunk/examples/jms/reconnect-same-node/src/org/hornetq/jms/ trunk/examples/jms/reconnect-same-node/src/org/hornetq/jms/example/ trunk/examples/jms/request-reply/src/org/hornetq/ trunk/examples/jms/request-reply/src/org/hornetq/jms/ trunk/examples/jms/request-reply/src/org/hornetq/jms/example/ trunk/examples/jms/scheduled-message/src/org/hornetq/ trunk/examples/jms/scheduled-message/src/org/hornetq/jms/ trunk/examples/jms/scheduled-message/src/org/hornetq/jms/example/ trunk/examples/jms/security/src/org/hornetq/ trunk/examples/jms/security/src/org/hornetq/jms/ trunk/examples/jms/security/src/org/hornetq/jms/example/ trunk/examples/jms/send-acknowledgements/src/org/hornetq/ trunk/examples/jms/send-acknowledgements/src/org/hornetq/jms/ trunk/examples/jms/send-acknowledgements/src/org/hornetq/jms/example/ trunk/examples/jms/ssl-enabled/src/org/hornetq/ trunk/examples/jms/ssl-enabled/src/org/hornetq/jms/ trunk/examples/jms/ssl-enabled/src/org/hornetq/jms/example/ trunk/examples/jms/static-selector-jms/src/org/hornetq/ trunk/examples/jms/static-selector-jms/src/org/hornetq/jms/ trunk/examples/jms/static-selector-jms/src/org/hornetq/jms/example/ trunk/examples/jms/static-selector/src/org/hornetq/ trunk/examples/jms/static-selector/src/org/hornetq/jms/ trunk/examples/jms/static-selector/src/org/hornetq/jms/example/ trunk/examples/jms/symmetric-cluster/src/org/hornetq/ trunk/examples/jms/symmetric-cluster/src/org/hornetq/jms/ trunk/examples/jms/symmetric-cluster/src/org/hornetq/jms/example/ trunk/examples/jms/temp-queue/src/org/hornetq/ trunk/examples/jms/temp-queue/src/org/hornetq/jms/ trunk/examples/jms/temp-queue/src/org/hornetq/jms/example/ trunk/examples/jms/topic-hierarchies/src/org/hornetq/ trunk/examples/jms/topic-hierarchies/src/org/hornetq/jms/ trunk/examples/jms/topic-hierarchies/src/org/hornetq/jms/example/ trunk/examples/jms/topic-selector-example1/src/org/hornetq/ trunk/examples/jms/topic-selector-example1/src/org/hornetq/jms/ trunk/examples/jms/topic-selector-example1/src/org/hornetq/jms/example/ trunk/examples/jms/topic-selector-example2/src/org/hornetq/ trunk/examples/jms/topic-selector-example2/src/org/hornetq/jms/ trunk/examples/jms/topic-selector-example2/src/org/hornetq/jms/example/ trunk/examples/jms/topic/src/org/hornetq/ trunk/examples/jms/topic/src/org/hornetq/jms/ trunk/examples/jms/topic/src/org/hornetq/jms/example/ trunk/examples/jms/transactional/src/org/hornetq/ trunk/examples/jms/transactional/src/org/hornetq/jms/ trunk/examples/jms/transactional/src/org/hornetq/jms/example/ trunk/examples/jms/xa-heuristic/src/org/hornetq/ trunk/examples/jms/xa-heuristic/src/org/hornetq/jms/ trunk/examples/jms/xa-heuristic/src/org/hornetq/jms/example/ trunk/examples/jms/xa-receive/src/org/hornetq/ trunk/examples/jms/xa-receive/src/org/hornetq/jms/ trunk/examples/jms/xa-receive/src/org/hornetq/jms/example/ trunk/examples/jms/xa-send/src/org/hornetq/ trunk/examples/jms/xa-send/src/org/hornetq/jms/ trunk/examples/jms/xa-send/src/org/hornetq/jms/example/ trunk/examples/jms/xa-with-jta/src/org/hornetq/ trunk/examples/jms/xa-with-jta/src/org/hornetq/jms/ trunk/examples/jms/xa-with-jta/src/org/hornetq/jms/example/ trunk/examples/soak/normal/src/org/hornetq/ trunk/examples/soak/normal/src/org/hornetq/jms/ trunk/examples/soak/normal/src/org/hornetq/jms/soak/ trunk/examples/soak/normal/src/org/hornetq/jms/soak/example/ Removed: trunk/examples/javaee/ejb-jms-transaction/src/org/jboss/javaee/example/EJBClientExample.java trunk/examples/javaee/ejb-jms-transaction/src/org/jboss/javaee/example/server/ trunk/examples/javaee/hajndi/src/org/jboss/javaee/example/ trunk/examples/javaee/jms-bridge/src/org/jboss/javaee/example/ trunk/examples/javaee/mdb-bmt/src/org/jboss/javaee/example/MDB_BMTClientExample.java trunk/examples/javaee/mdb-bmt/src/org/jboss/javaee/example/server/ trunk/examples/javaee/mdb-cmt-setrollbackonly/src/org/jboss/javaee/example/MDB_CMT_SetRollbackOnlyClientExample.java trunk/examples/javaee/mdb-cmt-setrollbackonly/src/org/jboss/javaee/example/server/ trunk/examples/javaee/mdb-cmt-tx-local/src/org/jboss/javaee/example/MDB_CMT_TxLocalClientExample.java trunk/examples/javaee/mdb-cmt-tx-local/src/org/jboss/javaee/example/server/ trunk/examples/javaee/mdb-cmt-tx-not-supported/src/org/jboss/javaee/example/MDB_CMT_TxNotSupportedClientExample.java trunk/examples/javaee/mdb-cmt-tx-not-supported/src/org/jboss/javaee/example/server/ trunk/examples/javaee/mdb-cmt-tx-required/src/org/jboss/javaee/example/MDB_CMT_TxRequiredClientExample.java trunk/examples/javaee/mdb-cmt-tx-required/src/org/jboss/javaee/example/server/ trunk/examples/javaee/servlet-ssl-example/src/org/jboss/javaee/example/ trunk/examples/javaee/servlet-transport/src/org/jboss/javaee/example/ trunk/examples/javaee/xarecovery/src/org/jboss/javaee/example/XARecoveryExample.java trunk/examples/javaee/xarecovery/src/org/jboss/javaee/example/server/ trunk/examples/jms/management-notifications/src/org/jboss/jms/example/ trunk/examples/jms/management/src/org/jboss/jms/example/ trunk/examples/jms/message-counters/src/org/jboss/jms/example/ trunk/examples/jms/message-group/src/org/jboss/jms/example/ trunk/examples/jms/message-priority/src/org/jboss/jms/example/ trunk/examples/jms/no-consumer-buffering/src/org/jboss/jms/example/ trunk/examples/jms/paging/src/org/jboss/jms/example/ trunk/examples/jms/perf/src/org/jboss/jms/example/ trunk/examples/jms/pre-acknowledge/src/org/jboss/jms/example/ trunk/examples/jms/producer-rate-limit/src/org/jboss/jms/example/ trunk/examples/jms/queue-message-redistribution/src/org/jboss/jms/example/ trunk/examples/jms/queue-requestor/src/org/jboss/jms/example/ trunk/examples/jms/queue-selector/src/org/jboss/jms/example/ trunk/examples/jms/queue/src/org/jboss/jms/example/ trunk/examples/jms/reconnect-same-node/src/org/jboss/jms/example/ trunk/examples/jms/request-reply/src/org/jboss/jms/example/ trunk/examples/jms/scheduled-message/src/org/jboss/jms/example/ trunk/examples/jms/security/src/org/jboss/jms/example/ trunk/examples/jms/send-acknowledgements/src/org/jboss/jms/example/ trunk/examples/jms/ssl-enabled/src/org/jboss/jms/example/ trunk/examples/jms/static-selector-jms/src/org/jboss/jms/example/ trunk/examples/jms/static-selector/src/org/jboss/jms/example/ trunk/examples/jms/symmetric-cluster/src/org/jboss/jms/example/ trunk/examples/jms/temp-queue/src/org/jboss/jms/example/ trunk/examples/jms/topic-hierarchies/src/org/jboss/jms/example/ trunk/examples/jms/topic-selector-example1/src/org/jboss/jms/example/ trunk/examples/jms/topic-selector-example2/src/org/jboss/jms/example/ trunk/examples/jms/topic/src/org/jboss/jms/example/ trunk/examples/jms/transactional/src/org/jboss/jms/example/ trunk/examples/jms/xa-heuristic/src/org/jboss/jms/example/ trunk/examples/jms/xa-receive/src/org/jboss/jms/example/ trunk/examples/jms/xa-send/src/org/jboss/jms/example/ trunk/examples/jms/xa-with-jta/src/org/jboss/jms/example/ trunk/examples/soak/normal/src/org/jboss/jms/soak/example/ Modified: trunk/docs/quickstart-guide/en/examples.xml trunk/examples/javaee/ejb-jms-transaction/build.xml trunk/examples/javaee/ejb-jms-transaction/src/org/hornetq/javaee/example/server/SendMessageBean.java trunk/examples/javaee/ejb-jms-transaction/src/org/hornetq/javaee/example/server/SendMessageService.java trunk/examples/javaee/hajndi/build.xml trunk/examples/javaee/hajndi/src/org/hornetq/javaee/example/HAJNDIExample.java trunk/examples/javaee/jca-config/build.xml trunk/examples/javaee/jca-config/src/org/jboss/javaee/example/MDBRemoteClientExample.java trunk/examples/javaee/jca-config/src/org/jboss/javaee/example/server/MDBQueueA.java trunk/examples/javaee/jca-config/src/org/jboss/javaee/example/server2/MDBQueueB.java trunk/examples/javaee/jca-config/src/org/jboss/javaee/example/server2/StatelessSender.java trunk/examples/javaee/jca-config/src/org/jboss/javaee/example/server2/StatelessSenderService.java trunk/examples/javaee/jms-bridge/build.xml trunk/examples/javaee/jms-bridge/src/org/hornetq/javaee/example/JMSBridgeExample.java trunk/examples/javaee/mdb-bmt/build.xml trunk/examples/javaee/mdb-bmt/src/org/hornetq/javaee/example/server/MDB_BMTExample.java trunk/examples/javaee/mdb-cmt-setrollbackonly/build.xml trunk/examples/javaee/mdb-cmt-setrollbackonly/src/org/hornetq/javaee/example/server/MDB_CMT_SetRollbackOnlyExample.java trunk/examples/javaee/mdb-cmt-tx-local/build.xml trunk/examples/javaee/mdb-cmt-tx-local/src/org/hornetq/javaee/example/server/MDB_CMT_TxLocalExample.java trunk/examples/javaee/mdb-cmt-tx-not-supported/build.xml trunk/examples/javaee/mdb-cmt-tx-not-supported/src/org/hornetq/javaee/example/server/MDB_CMT_TxNotSupported.java trunk/examples/javaee/mdb-cmt-tx-required/build.xml trunk/examples/javaee/mdb-cmt-tx-required/src/org/hornetq/javaee/example/server/MDB_CMT_TxRequiredExample.java trunk/examples/javaee/mdb-message-selector/build.xml trunk/examples/javaee/mdb-message-selector/src/org/jboss/javaee/example/MDBMessageSelectorClientExample.java trunk/examples/javaee/mdb-message-selector/src/org/jboss/javaee/example/server/MDBMessageSelectorExample.java trunk/examples/javaee/mdb-tx-send/build.xml trunk/examples/javaee/mdb-tx-send/src/org/jboss/javaee/example/MDBMessageSendTxClientExample.java trunk/examples/javaee/mdb-tx-send/src/org/jboss/javaee/example/server/MDBMessageSendTxExample.java trunk/examples/javaee/servlet-ssl-example/build.xml trunk/examples/javaee/servlet-ssl-example/src/org/hornetq/javaee/example/ServletSSLTransportExample.java trunk/examples/javaee/servlet-transport/build.xml trunk/examples/javaee/servlet-transport/src/org/hornetq/javaee/example/ServletTransportExample.java trunk/examples/javaee/xarecovery/build.xml trunk/examples/javaee/xarecovery/src/org/hornetq/javaee/example/server/XARecoveryExampleBean.java trunk/examples/javaee/xarecovery/src/org/hornetq/javaee/example/server/XARecoveryExampleService.java trunk/examples/jms/management-notifications/src/org/hornetq/jms/example/ManagementNotificationExample.java trunk/examples/jms/management/src/org/hornetq/jms/example/ManagementExample.java trunk/examples/jms/message-counters/src/org/hornetq/jms/example/MessageCounterExample.java trunk/examples/jms/message-group/src/org/hornetq/jms/example/MessageGroupExample.java trunk/examples/jms/message-priority/src/org/hornetq/jms/example/MessagePriorityExample.java trunk/examples/jms/no-consumer-buffering/src/org/hornetq/jms/example/NoConsumerBufferingExample.java trunk/examples/jms/paging/src/org/hornetq/jms/example/PagingExample.java trunk/examples/jms/perf/src/org/hornetq/jms/example/PerfBase.java trunk/examples/jms/perf/src/org/hornetq/jms/example/PerfListener.java trunk/examples/jms/perf/src/org/hornetq/jms/example/PerfParams.java trunk/examples/jms/perf/src/org/hornetq/jms/example/PerfSender.java trunk/examples/jms/pre-acknowledge/src/org/hornetq/jms/example/PreacknowledgeExample.java trunk/examples/jms/producer-rate-limit/src/org/hornetq/jms/example/ProducerRateLimitExample.java trunk/examples/jms/queue-message-redistribution/src/org/hornetq/jms/example/QueueMessageRedistributionExample.java trunk/examples/jms/queue-requestor/src/org/hornetq/jms/example/QueueRequestorExample.java trunk/examples/jms/queue-requestor/src/org/hornetq/jms/example/TextReverserService.java trunk/examples/jms/queue-selector/src/org/hornetq/jms/example/QueueSelectorExample.java trunk/examples/jms/queue/src/org/hornetq/jms/example/QueueExample.java trunk/examples/jms/reconnect-same-node/src/org/hornetq/jms/example/ReconnectSameNodeExample.java trunk/examples/jms/request-reply/src/org/hornetq/jms/example/RequestReplyExample.java trunk/examples/jms/scheduled-message/src/org/hornetq/jms/example/ScheduledMessageExample.java trunk/examples/jms/security/src/org/hornetq/jms/example/SecurityExample.java trunk/examples/jms/send-acknowledgements/src/org/hornetq/jms/example/SendAcknowledgementsExample.java trunk/examples/jms/ssl-enabled/src/org/hornetq/jms/example/SSLExample.java trunk/examples/jms/static-selector-jms/src/org/hornetq/jms/example/StaticSelectorJMSExample.java trunk/examples/jms/static-selector/src/org/hornetq/jms/example/StaticSelectorExample.java trunk/examples/jms/symmetric-cluster/src/org/hornetq/jms/example/SymmetricClusterExample.java trunk/examples/jms/temp-queue/src/org/hornetq/jms/example/TemporaryQueueExample.java trunk/examples/jms/topic-hierarchies/src/org/hornetq/jms/example/TopicHierarchyExample.java trunk/examples/jms/topic-selector-example1/src/org/hornetq/jms/example/TopicSelectorExample1.java trunk/examples/jms/topic-selector-example2/src/org/hornetq/jms/example/TopicSelectorExample2.java trunk/examples/jms/topic/src/org/hornetq/jms/example/TopicExample.java trunk/examples/jms/transactional/src/org/hornetq/jms/example/TransactionalExample.java trunk/examples/jms/xa-heuristic/src/org/hornetq/jms/example/XAHeuristicExample.java trunk/examples/jms/xa-receive/src/org/hornetq/jms/example/XAReceiveExample.java trunk/examples/jms/xa-send/src/org/hornetq/jms/example/XASendExample.java trunk/examples/jms/xa-with-jta/src/org/hornetq/jms/example/XAwithJTAExample.java trunk/examples/soak/normal/build.xml trunk/examples/soak/normal/src/org/hornetq/jms/soak/example/SoakBase.java trunk/examples/soak/normal/src/org/hornetq/jms/soak/example/SoakParams.java trunk/examples/soak/normal/src/org/hornetq/jms/soak/example/SoakReceiver.java trunk/examples/soak/normal/src/org/hornetq/jms/soak/example/SoakSender.java Log: Renaming examples packages Modified: trunk/docs/quickstart-guide/en/examples.xml =================================================================== --- trunk/docs/quickstart-guide/en/examples.xml 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/docs/quickstart-guide/en/examples.xml 2009-08-19 23:59:53 UTC (rev 7810) @@ -153,7 +153,7 @@ [exec] 16:01:04,607 INFO [JBossASKernel] Added bean(jboss.j2ee:ear=mdb-example.ear, jar=mdb-example.jar,name=MessageMDBExample,service=EJB3) to KernelDeployment of: mdb-example.jar - [exec] 16:01:04,702 INFO [EJBContainer] STARTED EJB: org.jboss.javaee.example.server + [exec] 16:01:04,702 INFO [EJBContainer] STARTED EJB: org.hornetq.javaee.example.server .MDBExample ejbName: MessageMDBExample [exec] 16:01:09,496 INFO [TomcatDeployment] deploy, ctxPath=/mdb-example [exec] 16:01:09,812 WARNING [config] Unable to process deployment descriptor for cont @@ -210,7 +210,7 @@ </programlisting> <para>You can verify that the application has been undeployed by checking the output from the JBoss Application Server, in this isntance it will be something like:</para> - <programlisting>16:36:45,277 INFO [EJBContainer] STOPPED EJB: org.jboss.javaee.example.server.MDBExample + <programlisting>16:36:45,277 INFO [EJBContainer] STOPPED EJB: org.hornetq.javaee.example.server.MDBExample ejbName: MessageMDBExample </programlisting> <para>Congratulations! you have sucessfully deployed and run a Java EE example.</para> Modified: trunk/examples/javaee/ejb-jms-transaction/build.xml =================================================================== --- trunk/examples/javaee/ejb-jms-transaction/build.xml 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/ejb-jms-transaction/build.xml 2009-08-19 23:59:53 UTC (rev 7810) @@ -40,7 +40,7 @@ <target name="run"> <antcall target="runExample"> - <param name="example.classname" value="org.jboss.javaee.example.EJBClientExample"/> + <param name="example.classname" value="org.hornetq.javaee.example.EJBClientExample"/> </antcall> </target> Copied: trunk/examples/javaee/ejb-jms-transaction/src/org/hornetq/javaee/example/EJBClientExample.java (from rev 7809, trunk/examples/javaee/ejb-jms-transaction/src/org/jboss/javaee/example/EJBClientExample.java) =================================================================== --- trunk/examples/javaee/ejb-jms-transaction/src/org/hornetq/javaee/example/EJBClientExample.java (rev 0) +++ trunk/examples/javaee/ejb-jms-transaction/src/org/hornetq/javaee/example/EJBClientExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -0,0 +1,95 @@ +/* + * JBoss, Home of Professional Open Source + * Copyright 2005-2008, Red Hat Middleware LLC, and individual contributors + * by the @authors tag. See the copyright.txt in the distribution for a + * full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package org.hornetq.javaee.example; + +import org.hornetq.javaee.example.server.SendMessageService; + +import javax.jms.Connection; +import javax.jms.ConnectionFactory; +import javax.jms.MessageConsumer; +import javax.jms.Queue; +import javax.jms.Session; +import javax.jms.TextMessage; +import javax.naming.InitialContext; + +/** + * An example showing how to invoke a EJB which sends a JMS message and update a JDBC table in the same transaction. + * + * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> + * @author <a href="mailto:jmesnil@redhat.com">Jeff Mesnil</a> + */ +public class EJBClientExample +{ + public static void main(String[] args) throws Exception + { + InitialContext initialContext = null; + Connection connection = null; + try + { + // Step 1. Obtain an Initial Context + initialContext = new InitialContext(); + + // Step 2. Lookup the EJB + SendMessageService service = (SendMessageService)initialContext.lookup("ejb-jms-transaction-example/SendMessageBean/remote"); + + // Step 3. Create the DB table which will be updated + service.createTable(); + + // Step 4. Invoke the sendAndUpdate method + service.sendAndUpdate("This is a text message"); + System.out.println("invoked the EJB service"); + + // Step 5. Lookup the JMS connection factory + ConnectionFactory cf = (ConnectionFactory)initialContext.lookup("/ConnectionFactory"); + + // Step 6. Lookup the queue + Queue queue = (Queue)initialContext.lookup("queue/testQueue"); + + // Step 7. Create a connection, a session and a message consumer for the queue + connection = cf.createConnection(); + Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); + MessageConsumer consumer = session.createConsumer(queue); + + // Step 8. Start the connection + connection.start(); + + // Step 9. Receive the message sent by the EJB + TextMessage messageReceived = (TextMessage)consumer.receive(5000); + System.out.println("Received message: " + messageReceived.getText() + + " (" + + messageReceived.getJMSMessageID() + + ")"); + } + finally + { + // Step 10. Be sure to close the resources! + if (initialContext != null) + { + initialContext.close(); + } + if (connection != null) + { + connection.close(); + } + } + } +} Copied: trunk/examples/javaee/ejb-jms-transaction/src/org/hornetq/javaee/example/server (from rev 7809, trunk/examples/javaee/ejb-jms-transaction/src/org/jboss/javaee/example/server) Modified: trunk/examples/javaee/ejb-jms-transaction/src/org/hornetq/javaee/example/server/SendMessageBean.java =================================================================== --- trunk/examples/javaee/ejb-jms-transaction/src/org/jboss/javaee/example/server/SendMessageBean.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/ejb-jms-transaction/src/org/hornetq/javaee/example/server/SendMessageBean.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.javaee.example.server; +package org.hornetq.javaee.example.server; import javax.ejb.Remote; import javax.ejb.Stateless; Modified: trunk/examples/javaee/ejb-jms-transaction/src/org/hornetq/javaee/example/server/SendMessageService.java =================================================================== --- trunk/examples/javaee/ejb-jms-transaction/src/org/jboss/javaee/example/server/SendMessageService.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/ejb-jms-transaction/src/org/hornetq/javaee/example/server/SendMessageService.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.javaee.example.server; +package org.hornetq.javaee.example.server; /** * The interface of an EJB which sends a JMS message and updates a JDBC table in the same transaction. Deleted: trunk/examples/javaee/ejb-jms-transaction/src/org/jboss/javaee/example/EJBClientExample.java =================================================================== --- trunk/examples/javaee/ejb-jms-transaction/src/org/jboss/javaee/example/EJBClientExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/ejb-jms-transaction/src/org/jboss/javaee/example/EJBClientExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -1,95 +0,0 @@ -/* - * JBoss, Home of Professional Open Source - * Copyright 2005-2008, Red Hat Middleware LLC, and individual contributors - * by the @authors tag. See the copyright.txt in the distribution for a - * full listing of individual contributors. - * - * This is free software; you can redistribute it and/or modify it - * under the terms of the GNU Lesser General Public License as - * published by the Free Software Foundation; either version 2.1 of - * the License, or (at your option) any later version. - * - * This software is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this software; if not, write to the Free - * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA - * 02110-1301 USA, or see the FSF site: http://www.fsf.org. - */ -package org.jboss.javaee.example; - -import org.jboss.javaee.example.server.SendMessageService; - -import javax.jms.Connection; -import javax.jms.ConnectionFactory; -import javax.jms.MessageConsumer; -import javax.jms.Queue; -import javax.jms.Session; -import javax.jms.TextMessage; -import javax.naming.InitialContext; - -/** - * An example showing how to invoke a EJB which sends a JMS message and update a JDBC table in the same transaction. - * - * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> - * @author <a href="mailto:jmesnil@redhat.com">Jeff Mesnil</a> - */ -public class EJBClientExample -{ - public static void main(String[] args) throws Exception - { - InitialContext initialContext = null; - Connection connection = null; - try - { - // Step 1. Obtain an Initial Context - initialContext = new InitialContext(); - - // Step 2. Lookup the EJB - SendMessageService service = (SendMessageService)initialContext.lookup("ejb-jms-transaction-example/SendMessageBean/remote"); - - // Step 3. Create the DB table which will be updated - service.createTable(); - - // Step 4. Invoke the sendAndUpdate method - service.sendAndUpdate("This is a text message"); - System.out.println("invoked the EJB service"); - - // Step 5. Lookup the JMS connection factory - ConnectionFactory cf = (ConnectionFactory)initialContext.lookup("/ConnectionFactory"); - - // Step 6. Lookup the queue - Queue queue = (Queue)initialContext.lookup("queue/testQueue"); - - // Step 7. Create a connection, a session and a message consumer for the queue - connection = cf.createConnection(); - Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); - MessageConsumer consumer = session.createConsumer(queue); - - // Step 8. Start the connection - connection.start(); - - // Step 9. Receive the message sent by the EJB - TextMessage messageReceived = (TextMessage)consumer.receive(5000); - System.out.println("Received message: " + messageReceived.getText() + - " (" + - messageReceived.getJMSMessageID() + - ")"); - } - finally - { - // Step 10. Be sure to close the resources! - if (initialContext != null) - { - initialContext.close(); - } - if (connection != null) - { - connection.close(); - } - } - } -} Modified: trunk/examples/javaee/hajndi/build.xml =================================================================== --- trunk/examples/javaee/hajndi/build.xml 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/hajndi/build.xml 2009-08-19 23:59:53 UTC (rev 7810) @@ -57,7 +57,7 @@ <target name="run"> <antcall target="runExample"> - <param name="example.classname" value="org.jboss.javaee.example.HAJNDIExample"/> + <param name="example.classname" value="org.hornetq.javaee.example.HAJNDIExample"/> </antcall> </target> Copied: trunk/examples/javaee/hajndi/src/org/hornetq/javaee/example (from rev 7809, trunk/examples/javaee/hajndi/src/org/jboss/javaee/example) Modified: trunk/examples/javaee/hajndi/src/org/hornetq/javaee/example/HAJNDIExample.java =================================================================== --- trunk/examples/javaee/hajndi/src/org/jboss/javaee/example/HAJNDIExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/hajndi/src/org/hornetq/javaee/example/HAJNDIExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.javaee.example; +package org.hornetq.javaee.example; import javax.jms.Connection; import javax.jms.ConnectionFactory; Modified: trunk/examples/javaee/jca-config/build.xml =================================================================== --- trunk/examples/javaee/jca-config/build.xml 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/jca-config/build.xml 2009-08-19 23:59:53 UTC (rev 7810) @@ -120,7 +120,7 @@ <target name="run"> <antcall target="runExample"> - <param name="example.classname" value="org.jboss.javaee.example.MDBRemoteClientExample"/> + <param name="example.classname" value="org.hornetq.javaee.example.MDBRemoteClientExample"/> </antcall> </target> Modified: trunk/examples/javaee/jca-config/src/org/jboss/javaee/example/MDBRemoteClientExample.java =================================================================== --- trunk/examples/javaee/jca-config/src/org/jboss/javaee/example/MDBRemoteClientExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/jca-config/src/org/jboss/javaee/example/MDBRemoteClientExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,9 +19,9 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.javaee.example; +package org.hornetq.javaee.example; -import org.jboss.javaee.example.server2.StatelessSenderService; +import org.hornetq.javaee.example.server2.StatelessSenderService; import javax.jms.Connection; import javax.naming.InitialContext; Modified: trunk/examples/javaee/jca-config/src/org/jboss/javaee/example/server/MDBQueueA.java =================================================================== --- trunk/examples/javaee/jca-config/src/org/jboss/javaee/example/server/MDBQueueA.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/jca-config/src/org/jboss/javaee/example/server/MDBQueueA.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.javaee.example.server; +package org.hornetq.javaee.example.server; import javax.ejb.ActivationConfigProperty; import javax.ejb.MessageDriven; Modified: trunk/examples/javaee/jca-config/src/org/jboss/javaee/example/server2/MDBQueueB.java =================================================================== --- trunk/examples/javaee/jca-config/src/org/jboss/javaee/example/server2/MDBQueueB.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/jca-config/src/org/jboss/javaee/example/server2/MDBQueueB.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.javaee.example.server2; +package org.hornetq.javaee.example.server2; import javax.ejb.ActivationConfigProperty; import javax.ejb.MessageDriven; Modified: trunk/examples/javaee/jca-config/src/org/jboss/javaee/example/server2/StatelessSender.java =================================================================== --- trunk/examples/javaee/jca-config/src/org/jboss/javaee/example/server2/StatelessSender.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/jca-config/src/org/jboss/javaee/example/server2/StatelessSender.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -21,7 +21,7 @@ */ -package org.jboss.javaee.example.server2; +package org.hornetq.javaee.example.server2; import org.hornetq.jms.JBossQueue; @@ -53,7 +53,7 @@ /* (non-Javadoc) - * @see org.jboss.javaee.example.server.StatelessSenderService#sendHello(java.lang.String) + * @see org.hornetq.javaee.example.server.StatelessSenderService#sendHello(java.lang.String) */ public void sendHello(String message) throws Exception { Modified: trunk/examples/javaee/jca-config/src/org/jboss/javaee/example/server2/StatelessSenderService.java =================================================================== --- trunk/examples/javaee/jca-config/src/org/jboss/javaee/example/server2/StatelessSenderService.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/jca-config/src/org/jboss/javaee/example/server2/StatelessSenderService.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -21,7 +21,7 @@ */ -package org.jboss.javaee.example.server2; +package org.hornetq.javaee.example.server2; /** * A StatelessSenderService Modified: trunk/examples/javaee/jms-bridge/build.xml =================================================================== --- trunk/examples/javaee/jms-bridge/build.xml 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/jms-bridge/build.xml 2009-08-19 23:59:53 UTC (rev 7810) @@ -31,7 +31,7 @@ <target name="run"> <antcall target="runExample"> - <param name="example.classname" value="org.jboss.javaee.example.JMSBridgeExample"/> + <param name="example.classname" value="org.hornetq.javaee.example.JMSBridgeExample"/> </antcall> </target> Copied: trunk/examples/javaee/jms-bridge/src/org/hornetq/javaee/example (from rev 7809, trunk/examples/javaee/jms-bridge/src/org/jboss/javaee/example) Modified: trunk/examples/javaee/jms-bridge/src/org/hornetq/javaee/example/JMSBridgeExample.java =================================================================== --- trunk/examples/javaee/jms-bridge/src/org/jboss/javaee/example/JMSBridgeExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/jms-bridge/src/org/hornetq/javaee/example/JMSBridgeExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.javaee.example; +package org.hornetq.javaee.example; import javax.jms.Connection; import javax.jms.ConnectionFactory; Modified: trunk/examples/javaee/mdb-bmt/build.xml =================================================================== --- trunk/examples/javaee/mdb-bmt/build.xml 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/mdb-bmt/build.xml 2009-08-19 23:59:53 UTC (rev 7810) @@ -31,7 +31,7 @@ <target name="run"> <antcall target="runExample"> - <param name="example.classname" value="org.jboss.javaee.example.MDB_BMTClientExample"/> + <param name="example.classname" value="org.hornetq.javaee.example.MDB_BMTClientExample"/> </antcall> </target> </project> \ No newline at end of file Copied: trunk/examples/javaee/mdb-bmt/src/org/hornetq/javaee/example/MDB_BMTClientExample.java (from rev 7809, trunk/examples/javaee/mdb-bmt/src/org/jboss/javaee/example/MDB_BMTClientExample.java) =================================================================== --- trunk/examples/javaee/mdb-bmt/src/org/hornetq/javaee/example/MDB_BMTClientExample.java (rev 0) +++ trunk/examples/javaee/mdb-bmt/src/org/hornetq/javaee/example/MDB_BMTClientExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -0,0 +1,84 @@ +/* + * JBoss, Home of Professional Open Source + * Copyright 2005-2008, Red Hat Middleware LLC, and individual contributors + * by the @authors tag. See the copyright.txt in the distribution for a + * full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package org.hornetq.javaee.example; + +import javax.jms.Connection; +import javax.jms.ConnectionFactory; +import javax.jms.MessageProducer; +import javax.jms.Queue; +import javax.jms.Session; +import javax.jms.TextMessage; +import javax.naming.InitialContext; + +/** + * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> + */ +public class MDB_BMTClientExample +{ + public static void main(String[] args) throws Exception + { + Connection connection = null; + InitialContext initialContext = null; + try + { + //Step 1. Create an initial context to perform the JNDI lookup. + initialContext = new InitialContext(); + + //Step 2. Perfom a lookup on the queue + Queue queue = (Queue) initialContext.lookup("/queue/testQueue"); + + //Step 3. Perform a lookup on the Connection Factory + ConnectionFactory cf = (ConnectionFactory) initialContext.lookup("/ConnectionFactory"); + + //Step 4.Create a JMS Connection + connection = cf.createConnection(); + + //Step 5. Create a JMS Session + Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); + + //Step 6. Create a JMS Message Producer + MessageProducer producer = session.createProducer(queue); + + //Step 7. Create a Text Message + TextMessage message = session.createTextMessage("This is a text message"); + + System.out.println("Sent message: " + message.getText()); + + //Step 8. Send the Message + producer.send(message); + + //Step 9, 10 and 11 in MDB_BMPExample + } + finally + { + //Step 12. Be sure to close our JMS resources! + if (initialContext != null) + { + initialContext.close(); + } + if(connection != null) + { + connection.close(); + } + } + } +} \ No newline at end of file Copied: trunk/examples/javaee/mdb-bmt/src/org/hornetq/javaee/example/server (from rev 7809, trunk/examples/javaee/mdb-bmt/src/org/jboss/javaee/example/server) Modified: trunk/examples/javaee/mdb-bmt/src/org/hornetq/javaee/example/server/MDB_BMTExample.java =================================================================== --- trunk/examples/javaee/mdb-bmt/src/org/jboss/javaee/example/server/MDB_BMTExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/mdb-bmt/src/org/hornetq/javaee/example/server/MDB_BMTExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.javaee.example.server; +package org.hornetq.javaee.example.server; import javax.annotation.Resource; import javax.ejb.ActivationConfigProperty; Deleted: trunk/examples/javaee/mdb-bmt/src/org/jboss/javaee/example/MDB_BMTClientExample.java =================================================================== --- trunk/examples/javaee/mdb-bmt/src/org/jboss/javaee/example/MDB_BMTClientExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/mdb-bmt/src/org/jboss/javaee/example/MDB_BMTClientExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -1,84 +0,0 @@ -/* - * JBoss, Home of Professional Open Source - * Copyright 2005-2008, Red Hat Middleware LLC, and individual contributors - * by the @authors tag. See the copyright.txt in the distribution for a - * full listing of individual contributors. - * - * This is free software; you can redistribute it and/or modify it - * under the terms of the GNU Lesser General Public License as - * published by the Free Software Foundation; either version 2.1 of - * the License, or (at your option) any later version. - * - * This software is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this software; if not, write to the Free - * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA - * 02110-1301 USA, or see the FSF site: http://www.fsf.org. - */ -package org.jboss.javaee.example; - -import javax.jms.Connection; -import javax.jms.ConnectionFactory; -import javax.jms.MessageProducer; -import javax.jms.Queue; -import javax.jms.Session; -import javax.jms.TextMessage; -import javax.naming.InitialContext; - -/** - * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> - */ -public class MDB_BMTClientExample -{ - public static void main(String[] args) throws Exception - { - Connection connection = null; - InitialContext initialContext = null; - try - { - //Step 1. Create an initial context to perform the JNDI lookup. - initialContext = new InitialContext(); - - //Step 2. Perfom a lookup on the queue - Queue queue = (Queue) initialContext.lookup("/queue/testQueue"); - - //Step 3. Perform a lookup on the Connection Factory - ConnectionFactory cf = (ConnectionFactory) initialContext.lookup("/ConnectionFactory"); - - //Step 4.Create a JMS Connection - connection = cf.createConnection(); - - //Step 5. Create a JMS Session - Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); - - //Step 6. Create a JMS Message Producer - MessageProducer producer = session.createProducer(queue); - - //Step 7. Create a Text Message - TextMessage message = session.createTextMessage("This is a text message"); - - System.out.println("Sent message: " + message.getText()); - - //Step 8. Send the Message - producer.send(message); - - //Step 9, 10 and 11 in MDB_BMPExample - } - finally - { - //Step 12. Be sure to close our JMS resources! - if (initialContext != null) - { - initialContext.close(); - } - if(connection != null) - { - connection.close(); - } - } - } -} \ No newline at end of file Modified: trunk/examples/javaee/mdb-cmt-setrollbackonly/build.xml =================================================================== --- trunk/examples/javaee/mdb-cmt-setrollbackonly/build.xml 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/mdb-cmt-setrollbackonly/build.xml 2009-08-19 23:59:53 UTC (rev 7810) @@ -31,7 +31,7 @@ <target name="run"> <antcall target="runExample"> - <param name="example.classname" value="org.jboss.javaee.example.MDB_CMT_SetRollbackOnlyClientExample"/> + <param name="example.classname" value="org.hornetq.javaee.example.MDB_CMT_SetRollbackOnlyClientExample"/> </antcall> </target> </project> \ No newline at end of file Copied: trunk/examples/javaee/mdb-cmt-setrollbackonly/src/org/hornetq/javaee/example/MDB_CMT_SetRollbackOnlyClientExample.java (from rev 7809, trunk/examples/javaee/mdb-cmt-setrollbackonly/src/org/jboss/javaee/example/MDB_CMT_SetRollbackOnlyClientExample.java) =================================================================== --- trunk/examples/javaee/mdb-cmt-setrollbackonly/src/org/hornetq/javaee/example/MDB_CMT_SetRollbackOnlyClientExample.java (rev 0) +++ trunk/examples/javaee/mdb-cmt-setrollbackonly/src/org/hornetq/javaee/example/MDB_CMT_SetRollbackOnlyClientExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -0,0 +1,84 @@ +/* + * JBoss, Home of Professional Open Source + * Copyright 2005-2008, Red Hat Middleware LLC, and individual contributors + * by the @authors tag. See the copyright.txt in the distribution for a + * full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package org.hornetq.javaee.example; + +import javax.jms.Connection; +import javax.jms.ConnectionFactory; +import javax.jms.MessageProducer; +import javax.jms.Queue; +import javax.jms.Session; +import javax.jms.TextMessage; +import javax.naming.InitialContext; + +/** + * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> + */ +public class MDB_CMT_SetRollbackOnlyClientExample +{ + public static void main(String[] args) throws Exception + { + Connection connection = null; + InitialContext initialContext = null; + try + { + //Step 1. Create an initial context to perform the JNDI lookup. + initialContext = new InitialContext(); + + //Step 2. Perfom a lookup on the queue + Queue queue = (Queue) initialContext.lookup("/queue/testQueue"); + + //Step 3. Perform a lookup on the Connection Factory + ConnectionFactory cf = (ConnectionFactory) initialContext.lookup("/ConnectionFactory"); + + //Step 4.Create a JMS Connection + connection = cf.createConnection(); + + //Step 5. Create a JMS Session + Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); + + //Step 6. Create a JMS Message Producer + MessageProducer producer = session.createProducer(queue); + + //Step 7. Create a Text Message + TextMessage message = session.createTextMessage("This is a text message"); + + System.out.println("Sent message: " + message.getText()); + + //Step 8. Send the Message + producer.send(message); + + //Step 9, 10, 11 and 12 in MDB_CMP_SetRollbackOnlyExample + } + finally + { + //Step 13. Be sure to close our JMS resources! + if (initialContext != null) + { + initialContext.close(); + } + if(connection != null) + { + connection.close(); + } + } + } +} \ No newline at end of file Copied: trunk/examples/javaee/mdb-cmt-setrollbackonly/src/org/hornetq/javaee/example/server (from rev 7809, trunk/examples/javaee/mdb-cmt-setrollbackonly/src/org/jboss/javaee/example/server) Modified: trunk/examples/javaee/mdb-cmt-setrollbackonly/src/org/hornetq/javaee/example/server/MDB_CMT_SetRollbackOnlyExample.java =================================================================== --- trunk/examples/javaee/mdb-cmt-setrollbackonly/src/org/jboss/javaee/example/server/MDB_CMT_SetRollbackOnlyExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/mdb-cmt-setrollbackonly/src/org/hornetq/javaee/example/server/MDB_CMT_SetRollbackOnlyExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.javaee.example.server; +package org.hornetq.javaee.example.server; import javax.annotation.Resource; import javax.ejb.ActivationConfigProperty; Deleted: trunk/examples/javaee/mdb-cmt-setrollbackonly/src/org/jboss/javaee/example/MDB_CMT_SetRollbackOnlyClientExample.java =================================================================== --- trunk/examples/javaee/mdb-cmt-setrollbackonly/src/org/jboss/javaee/example/MDB_CMT_SetRollbackOnlyClientExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/mdb-cmt-setrollbackonly/src/org/jboss/javaee/example/MDB_CMT_SetRollbackOnlyClientExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -1,84 +0,0 @@ -/* - * JBoss, Home of Professional Open Source - * Copyright 2005-2008, Red Hat Middleware LLC, and individual contributors - * by the @authors tag. See the copyright.txt in the distribution for a - * full listing of individual contributors. - * - * This is free software; you can redistribute it and/or modify it - * under the terms of the GNU Lesser General Public License as - * published by the Free Software Foundation; either version 2.1 of - * the License, or (at your option) any later version. - * - * This software is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this software; if not, write to the Free - * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA - * 02110-1301 USA, or see the FSF site: http://www.fsf.org. - */ -package org.jboss.javaee.example; - -import javax.jms.Connection; -import javax.jms.ConnectionFactory; -import javax.jms.MessageProducer; -import javax.jms.Queue; -import javax.jms.Session; -import javax.jms.TextMessage; -import javax.naming.InitialContext; - -/** - * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> - */ -public class MDB_CMT_SetRollbackOnlyClientExample -{ - public static void main(String[] args) throws Exception - { - Connection connection = null; - InitialContext initialContext = null; - try - { - //Step 1. Create an initial context to perform the JNDI lookup. - initialContext = new InitialContext(); - - //Step 2. Perfom a lookup on the queue - Queue queue = (Queue) initialContext.lookup("/queue/testQueue"); - - //Step 3. Perform a lookup on the Connection Factory - ConnectionFactory cf = (ConnectionFactory) initialContext.lookup("/ConnectionFactory"); - - //Step 4.Create a JMS Connection - connection = cf.createConnection(); - - //Step 5. Create a JMS Session - Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); - - //Step 6. Create a JMS Message Producer - MessageProducer producer = session.createProducer(queue); - - //Step 7. Create a Text Message - TextMessage message = session.createTextMessage("This is a text message"); - - System.out.println("Sent message: " + message.getText()); - - //Step 8. Send the Message - producer.send(message); - - //Step 9, 10, 11 and 12 in MDB_CMP_SetRollbackOnlyExample - } - finally - { - //Step 13. Be sure to close our JMS resources! - if (initialContext != null) - { - initialContext.close(); - } - if(connection != null) - { - connection.close(); - } - } - } -} \ No newline at end of file Modified: trunk/examples/javaee/mdb-cmt-tx-local/build.xml =================================================================== --- trunk/examples/javaee/mdb-cmt-tx-local/build.xml 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/mdb-cmt-tx-local/build.xml 2009-08-19 23:59:53 UTC (rev 7810) @@ -31,7 +31,7 @@ <target name="run"> <antcall target="runExample"> - <param name="example.classname" value="org.jboss.javaee.example.MDB_CMT_TxLocalClientExample"/> + <param name="example.classname" value="org.hornetq.javaee.example.MDB_CMT_TxLocalClientExample"/> </antcall> </target> </project> \ No newline at end of file Copied: trunk/examples/javaee/mdb-cmt-tx-local/src/org/hornetq/javaee/example/MDB_CMT_TxLocalClientExample.java (from rev 7809, trunk/examples/javaee/mdb-cmt-tx-local/src/org/jboss/javaee/example/MDB_CMT_TxLocalClientExample.java) =================================================================== --- trunk/examples/javaee/mdb-cmt-tx-local/src/org/hornetq/javaee/example/MDB_CMT_TxLocalClientExample.java (rev 0) +++ trunk/examples/javaee/mdb-cmt-tx-local/src/org/hornetq/javaee/example/MDB_CMT_TxLocalClientExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -0,0 +1,84 @@ +/* + * JBoss, Home of Professional Open Source + * Copyright 2005-2008, Red Hat Middleware LLC, and individual contributors + * by the @authors tag. See the copyright.txt in the distribution for a + * full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package org.hornetq.javaee.example; + +import javax.jms.Connection; +import javax.jms.ConnectionFactory; +import javax.jms.MessageProducer; +import javax.jms.Queue; +import javax.jms.Session; +import javax.jms.TextMessage; +import javax.naming.InitialContext; + +/** + * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> + */ +public class MDB_CMT_TxLocalClientExample +{ + public static void main(String[] args) throws Exception + { + Connection connection = null; + InitialContext initialContext = null; + try + { + //Step 1. Create an initial context to perform the JNDI lookup. + initialContext = new InitialContext(); + + //Step 2. Perfom a lookup on the queue + Queue queue = (Queue) initialContext.lookup("/queue/testQueue"); + + //Step 3. Perform a lookup on the Connection Factory + ConnectionFactory cf = (ConnectionFactory) initialContext.lookup("/ConnectionFactory"); + + //Step 4.Create a JMS Connection + connection = cf.createConnection(); + + //Step 5. Create a JMS Session + Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); + + //Step 6. Create a JMS Message Producer + MessageProducer producer = session.createProducer(queue); + + //Step 7. Create a Text Message + TextMessage message = session.createTextMessage("This is a text message"); + + System.out.println("Sent message: " + message.getText()); + + //Step 8. Send the Message + producer.send(message); + + //Step 9,,10, 11 and 12 in MDB_CMP_TxLocalExample + } + finally + { + //Step 13. Be sure to close our JMS resources! + if (initialContext != null) + { + initialContext.close(); + } + if(connection != null) + { + connection.close(); + } + } + } +} \ No newline at end of file Copied: trunk/examples/javaee/mdb-cmt-tx-local/src/org/hornetq/javaee/example/server (from rev 7809, trunk/examples/javaee/mdb-cmt-tx-local/src/org/jboss/javaee/example/server) Modified: trunk/examples/javaee/mdb-cmt-tx-local/src/org/hornetq/javaee/example/server/MDB_CMT_TxLocalExample.java =================================================================== --- trunk/examples/javaee/mdb-cmt-tx-local/src/org/jboss/javaee/example/server/MDB_CMT_TxLocalExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/mdb-cmt-tx-local/src/org/hornetq/javaee/example/server/MDB_CMT_TxLocalExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.javaee.example.server; +package org.hornetq.javaee.example.server; import javax.annotation.Resource; import javax.ejb.ActivationConfigProperty; Deleted: trunk/examples/javaee/mdb-cmt-tx-local/src/org/jboss/javaee/example/MDB_CMT_TxLocalClientExample.java =================================================================== --- trunk/examples/javaee/mdb-cmt-tx-local/src/org/jboss/javaee/example/MDB_CMT_TxLocalClientExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/mdb-cmt-tx-local/src/org/jboss/javaee/example/MDB_CMT_TxLocalClientExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -1,84 +0,0 @@ -/* - * JBoss, Home of Professional Open Source - * Copyright 2005-2008, Red Hat Middleware LLC, and individual contributors - * by the @authors tag. See the copyright.txt in the distribution for a - * full listing of individual contributors. - * - * This is free software; you can redistribute it and/or modify it - * under the terms of the GNU Lesser General Public License as - * published by the Free Software Foundation; either version 2.1 of - * the License, or (at your option) any later version. - * - * This software is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this software; if not, write to the Free - * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA - * 02110-1301 USA, or see the FSF site: http://www.fsf.org. - */ -package org.jboss.javaee.example; - -import javax.jms.Connection; -import javax.jms.ConnectionFactory; -import javax.jms.MessageProducer; -import javax.jms.Queue; -import javax.jms.Session; -import javax.jms.TextMessage; -import javax.naming.InitialContext; - -/** - * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> - */ -public class MDB_CMT_TxLocalClientExample -{ - public static void main(String[] args) throws Exception - { - Connection connection = null; - InitialContext initialContext = null; - try - { - //Step 1. Create an initial context to perform the JNDI lookup. - initialContext = new InitialContext(); - - //Step 2. Perfom a lookup on the queue - Queue queue = (Queue) initialContext.lookup("/queue/testQueue"); - - //Step 3. Perform a lookup on the Connection Factory - ConnectionFactory cf = (ConnectionFactory) initialContext.lookup("/ConnectionFactory"); - - //Step 4.Create a JMS Connection - connection = cf.createConnection(); - - //Step 5. Create a JMS Session - Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); - - //Step 6. Create a JMS Message Producer - MessageProducer producer = session.createProducer(queue); - - //Step 7. Create a Text Message - TextMessage message = session.createTextMessage("This is a text message"); - - System.out.println("Sent message: " + message.getText()); - - //Step 8. Send the Message - producer.send(message); - - //Step 9,,10, 11 and 12 in MDB_CMP_TxLocalExample - } - finally - { - //Step 13. Be sure to close our JMS resources! - if (initialContext != null) - { - initialContext.close(); - } - if(connection != null) - { - connection.close(); - } - } - } -} \ No newline at end of file Modified: trunk/examples/javaee/mdb-cmt-tx-not-supported/build.xml =================================================================== --- trunk/examples/javaee/mdb-cmt-tx-not-supported/build.xml 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/mdb-cmt-tx-not-supported/build.xml 2009-08-19 23:59:53 UTC (rev 7810) @@ -31,7 +31,7 @@ <target name="run"> <antcall target="runExample"> - <param name="example.classname" value="org.jboss.javaee.example.MDB_CMT_TxNotSupportedClientExample"/> + <param name="example.classname" value="org.hornetq.javaee.example.MDB_CMT_TxNotSupportedClientExample"/> </antcall> </target> </project> \ No newline at end of file Copied: trunk/examples/javaee/mdb-cmt-tx-not-supported/src/org/hornetq/javaee/example/MDB_CMT_TxNotSupportedClientExample.java (from rev 7809, trunk/examples/javaee/mdb-cmt-tx-not-supported/src/org/jboss/javaee/example/MDB_CMT_TxNotSupportedClientExample.java) =================================================================== --- trunk/examples/javaee/mdb-cmt-tx-not-supported/src/org/hornetq/javaee/example/MDB_CMT_TxNotSupportedClientExample.java (rev 0) +++ trunk/examples/javaee/mdb-cmt-tx-not-supported/src/org/hornetq/javaee/example/MDB_CMT_TxNotSupportedClientExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -0,0 +1,84 @@ +/* + * JBoss, Home of Professional Open Source + * Copyright 2005-2008, Red Hat Middleware LLC, and individual contributors + * by the @authors tag. See the copyright.txt in the distribution for a + * full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package org.hornetq.javaee.example; + +import javax.jms.Connection; +import javax.jms.ConnectionFactory; +import javax.jms.MessageProducer; +import javax.jms.Queue; +import javax.jms.Session; +import javax.jms.TextMessage; +import javax.naming.InitialContext; + +/** + * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> + */ +public class MDB_CMT_TxNotSupportedClientExample +{ + public static void main(String[] args) throws Exception + { + Connection connection = null; + InitialContext initialContext = null; + try + { + //Step 1. Create an initial context to perform the JNDI lookup. + initialContext = new InitialContext(); + + //Step 2. Perfom a lookup on the queue + Queue queue = (Queue) initialContext.lookup("/queue/testQueue"); + + //Step 3. Perform a lookup on the Connection Factory + ConnectionFactory cf = (ConnectionFactory) initialContext.lookup("/ConnectionFactory"); + + //Step 4.Create a JMS Connection + connection = cf.createConnection(); + + //Step 5. Create a JMS Session + Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); + + //Step 6. Create a JMS Message Producer + MessageProducer producer = session.createProducer(queue); + + //Step 7. Create a Text Message + TextMessage message = session.createTextMessage("This is a text message"); + + System.out.println("Sent message: " + message.getText()); + + //Step 8. Send the Message + producer.send(message); + + //Step 9,10 and 11 in MDB_CMP_TxNotSupported + } + finally + { + //Step 12. Be sure to close our JMS resources! + if (initialContext != null) + { + initialContext.close(); + } + if(connection != null) + { + connection.close(); + } + } + } +} \ No newline at end of file Copied: trunk/examples/javaee/mdb-cmt-tx-not-supported/src/org/hornetq/javaee/example/server (from rev 7809, trunk/examples/javaee/mdb-cmt-tx-not-supported/src/org/jboss/javaee/example/server) Modified: trunk/examples/javaee/mdb-cmt-tx-not-supported/src/org/hornetq/javaee/example/server/MDB_CMT_TxNotSupported.java =================================================================== --- trunk/examples/javaee/mdb-cmt-tx-not-supported/src/org/jboss/javaee/example/server/MDB_CMT_TxNotSupported.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/mdb-cmt-tx-not-supported/src/org/hornetq/javaee/example/server/MDB_CMT_TxNotSupported.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.javaee.example.server; +package org.hornetq.javaee.example.server; import javax.annotation.Resource; import javax.ejb.ActivationConfigProperty; Deleted: trunk/examples/javaee/mdb-cmt-tx-not-supported/src/org/jboss/javaee/example/MDB_CMT_TxNotSupportedClientExample.java =================================================================== --- trunk/examples/javaee/mdb-cmt-tx-not-supported/src/org/jboss/javaee/example/MDB_CMT_TxNotSupportedClientExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/mdb-cmt-tx-not-supported/src/org/jboss/javaee/example/MDB_CMT_TxNotSupportedClientExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -1,84 +0,0 @@ -/* - * JBoss, Home of Professional Open Source - * Copyright 2005-2008, Red Hat Middleware LLC, and individual contributors - * by the @authors tag. See the copyright.txt in the distribution for a - * full listing of individual contributors. - * - * This is free software; you can redistribute it and/or modify it - * under the terms of the GNU Lesser General Public License as - * published by the Free Software Foundation; either version 2.1 of - * the License, or (at your option) any later version. - * - * This software is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this software; if not, write to the Free - * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA - * 02110-1301 USA, or see the FSF site: http://www.fsf.org. - */ -package org.jboss.javaee.example; - -import javax.jms.Connection; -import javax.jms.ConnectionFactory; -import javax.jms.MessageProducer; -import javax.jms.Queue; -import javax.jms.Session; -import javax.jms.TextMessage; -import javax.naming.InitialContext; - -/** - * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> - */ -public class MDB_CMT_TxNotSupportedClientExample -{ - public static void main(String[] args) throws Exception - { - Connection connection = null; - InitialContext initialContext = null; - try - { - //Step 1. Create an initial context to perform the JNDI lookup. - initialContext = new InitialContext(); - - //Step 2. Perfom a lookup on the queue - Queue queue = (Queue) initialContext.lookup("/queue/testQueue"); - - //Step 3. Perform a lookup on the Connection Factory - ConnectionFactory cf = (ConnectionFactory) initialContext.lookup("/ConnectionFactory"); - - //Step 4.Create a JMS Connection - connection = cf.createConnection(); - - //Step 5. Create a JMS Session - Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); - - //Step 6. Create a JMS Message Producer - MessageProducer producer = session.createProducer(queue); - - //Step 7. Create a Text Message - TextMessage message = session.createTextMessage("This is a text message"); - - System.out.println("Sent message: " + message.getText()); - - //Step 8. Send the Message - producer.send(message); - - //Step 9,10 and 11 in MDB_CMP_TxNotSupported - } - finally - { - //Step 12. Be sure to close our JMS resources! - if (initialContext != null) - { - initialContext.close(); - } - if(connection != null) - { - connection.close(); - } - } - } -} \ No newline at end of file Modified: trunk/examples/javaee/mdb-cmt-tx-required/build.xml =================================================================== --- trunk/examples/javaee/mdb-cmt-tx-required/build.xml 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/mdb-cmt-tx-required/build.xml 2009-08-19 23:59:53 UTC (rev 7810) @@ -31,7 +31,7 @@ <target name="run"> <antcall target="runExample"> - <param name="example.classname" value="org.jboss.javaee.example.MDB_CMT_TxRequiredClientExample"/> + <param name="example.classname" value="org.hornetq.javaee.example.MDB_CMT_TxRequiredClientExample"/> </antcall> </target> </project> \ No newline at end of file Copied: trunk/examples/javaee/mdb-cmt-tx-required/src/org/hornetq/javaee/example/MDB_CMT_TxRequiredClientExample.java (from rev 7809, trunk/examples/javaee/mdb-cmt-tx-required/src/org/jboss/javaee/example/MDB_CMT_TxRequiredClientExample.java) =================================================================== --- trunk/examples/javaee/mdb-cmt-tx-required/src/org/hornetq/javaee/example/MDB_CMT_TxRequiredClientExample.java (rev 0) +++ trunk/examples/javaee/mdb-cmt-tx-required/src/org/hornetq/javaee/example/MDB_CMT_TxRequiredClientExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -0,0 +1,84 @@ +/* + * JBoss, Home of Professional Open Source + * Copyright 2005-2008, Red Hat Middleware LLC, and individual contributors + * by the @authors tag. See the copyright.txt in the distribution for a + * full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package org.hornetq.javaee.example; + +import javax.jms.Connection; +import javax.jms.ConnectionFactory; +import javax.jms.MessageProducer; +import javax.jms.Queue; +import javax.jms.Session; +import javax.jms.TextMessage; +import javax.naming.InitialContext; + +/** + * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> + */ +public class MDB_CMT_TxRequiredClientExample +{ + public static void main(String[] args) throws Exception + { + Connection connection = null; + InitialContext initialContext = null; + try + { + //Step 1. Create an initial context to perform the JNDI lookup. + initialContext = new InitialContext(); + + //Step 2. Perfom a lookup on the queue + Queue queue = (Queue) initialContext.lookup("/queue/testQueue"); + + //Step 3. Perform a lookup on the Connection Factory + ConnectionFactory cf = (ConnectionFactory) initialContext.lookup("/ConnectionFactory"); + + //Step 4.Create a JMS Connection + connection = cf.createConnection(); + + //Step 5. Create a JMS Session + Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); + + //Step 6. Create a JMS Message Producer + MessageProducer producer = session.createProducer(queue); + + //Step 7. Create a Text Message + TextMessage message = session.createTextMessage("This is a text message"); + + System.out.println("Sent message: " + message.getText()); + + //Step 8. Send the Message + producer.send(message); + + //Step 9,10 and 11 in MDBExample + } + finally + { + //Step 12. Be sure to close our JMS resources! + if (initialContext != null) + { + initialContext.close(); + } + if(connection != null) + { + connection.close(); + } + } + } +} Copied: trunk/examples/javaee/mdb-cmt-tx-required/src/org/hornetq/javaee/example/server (from rev 7809, trunk/examples/javaee/mdb-cmt-tx-required/src/org/jboss/javaee/example/server) Modified: trunk/examples/javaee/mdb-cmt-tx-required/src/org/hornetq/javaee/example/server/MDB_CMT_TxRequiredExample.java =================================================================== --- trunk/examples/javaee/mdb-cmt-tx-required/src/org/jboss/javaee/example/server/MDB_CMT_TxRequiredExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/mdb-cmt-tx-required/src/org/hornetq/javaee/example/server/MDB_CMT_TxRequiredExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.javaee.example.server; +package org.hornetq.javaee.example.server; import javax.annotation.Resource; import javax.ejb.ActivationConfigProperty; Deleted: trunk/examples/javaee/mdb-cmt-tx-required/src/org/jboss/javaee/example/MDB_CMT_TxRequiredClientExample.java =================================================================== --- trunk/examples/javaee/mdb-cmt-tx-required/src/org/jboss/javaee/example/MDB_CMT_TxRequiredClientExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/mdb-cmt-tx-required/src/org/jboss/javaee/example/MDB_CMT_TxRequiredClientExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -1,84 +0,0 @@ -/* - * JBoss, Home of Professional Open Source - * Copyright 2005-2008, Red Hat Middleware LLC, and individual contributors - * by the @authors tag. See the copyright.txt in the distribution for a - * full listing of individual contributors. - * - * This is free software; you can redistribute it and/or modify it - * under the terms of the GNU Lesser General Public License as - * published by the Free Software Foundation; either version 2.1 of - * the License, or (at your option) any later version. - * - * This software is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this software; if not, write to the Free - * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA - * 02110-1301 USA, or see the FSF site: http://www.fsf.org. - */ -package org.jboss.javaee.example; - -import javax.jms.Connection; -import javax.jms.ConnectionFactory; -import javax.jms.MessageProducer; -import javax.jms.Queue; -import javax.jms.Session; -import javax.jms.TextMessage; -import javax.naming.InitialContext; - -/** - * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> - */ -public class MDB_CMT_TxRequiredClientExample -{ - public static void main(String[] args) throws Exception - { - Connection connection = null; - InitialContext initialContext = null; - try - { - //Step 1. Create an initial context to perform the JNDI lookup. - initialContext = new InitialContext(); - - //Step 2. Perfom a lookup on the queue - Queue queue = (Queue) initialContext.lookup("/queue/testQueue"); - - //Step 3. Perform a lookup on the Connection Factory - ConnectionFactory cf = (ConnectionFactory) initialContext.lookup("/ConnectionFactory"); - - //Step 4.Create a JMS Connection - connection = cf.createConnection(); - - //Step 5. Create a JMS Session - Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); - - //Step 6. Create a JMS Message Producer - MessageProducer producer = session.createProducer(queue); - - //Step 7. Create a Text Message - TextMessage message = session.createTextMessage("This is a text message"); - - System.out.println("Sent message: " + message.getText()); - - //Step 8. Send the Message - producer.send(message); - - //Step 9,10 and 11 in MDBExample - } - finally - { - //Step 12. Be sure to close our JMS resources! - if (initialContext != null) - { - initialContext.close(); - } - if(connection != null) - { - connection.close(); - } - } - } -} Modified: trunk/examples/javaee/mdb-message-selector/build.xml =================================================================== --- trunk/examples/javaee/mdb-message-selector/build.xml 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/mdb-message-selector/build.xml 2009-08-19 23:59:53 UTC (rev 7810) @@ -31,7 +31,7 @@ <target name="run"> <antcall target="runExample"> - <param name="example.classname" value="org.jboss.javaee.example.MDBMessageSelectorClientExample"/> + <param name="example.classname" value="org.hornetq.javaee.example.MDBMessageSelectorClientExample"/> </antcall> </target> </project> \ No newline at end of file Modified: trunk/examples/javaee/mdb-message-selector/src/org/jboss/javaee/example/MDBMessageSelectorClientExample.java =================================================================== --- trunk/examples/javaee/mdb-message-selector/src/org/jboss/javaee/example/MDBMessageSelectorClientExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/mdb-message-selector/src/org/jboss/javaee/example/MDBMessageSelectorClientExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.javaee.example; +package org.hornetq.javaee.example; import javax.jms.Connection; import javax.jms.ConnectionFactory; Modified: trunk/examples/javaee/mdb-message-selector/src/org/jboss/javaee/example/server/MDBMessageSelectorExample.java =================================================================== --- trunk/examples/javaee/mdb-message-selector/src/org/jboss/javaee/example/server/MDBMessageSelectorExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/mdb-message-selector/src/org/jboss/javaee/example/server/MDBMessageSelectorExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.javaee.example.server; +package org.hornetq.javaee.example.server; import javax.ejb.ActivationConfigProperty; import javax.ejb.MessageDriven; Modified: trunk/examples/javaee/mdb-tx-send/build.xml =================================================================== --- trunk/examples/javaee/mdb-tx-send/build.xml 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/mdb-tx-send/build.xml 2009-08-19 23:59:53 UTC (rev 7810) @@ -31,7 +31,7 @@ <target name="run"> <antcall target="runExample"> - <param name="example.classname" value="org.jboss.javaee.example.MDBMessageSendTxClientExample"/> + <param name="example.classname" value="org.hornetq.javaee.example.MDBMessageSendTxClientExample"/> </antcall> </target> </project> \ No newline at end of file Modified: trunk/examples/javaee/mdb-tx-send/src/org/jboss/javaee/example/MDBMessageSendTxClientExample.java =================================================================== --- trunk/examples/javaee/mdb-tx-send/src/org/jboss/javaee/example/MDBMessageSendTxClientExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/mdb-tx-send/src/org/jboss/javaee/example/MDBMessageSendTxClientExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.javaee.example; +package org.hornetq.javaee.example; import javax.jms.Connection; import javax.jms.ConnectionFactory; Modified: trunk/examples/javaee/mdb-tx-send/src/org/jboss/javaee/example/server/MDBMessageSendTxExample.java =================================================================== --- trunk/examples/javaee/mdb-tx-send/src/org/jboss/javaee/example/server/MDBMessageSendTxExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/mdb-tx-send/src/org/jboss/javaee/example/server/MDBMessageSendTxExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.javaee.example.server; +package org.hornetq.javaee.example.server; import javax.annotation.Resource; import javax.ejb.ActivationConfigProperty; Modified: trunk/examples/javaee/servlet-ssl-example/build.xml =================================================================== --- trunk/examples/javaee/servlet-ssl-example/build.xml 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/servlet-ssl-example/build.xml 2009-08-19 23:59:53 UTC (rev 7810) @@ -41,7 +41,7 @@ </target> <target name="run"> <antcall target="runExample"> - <param name="example.classname" value="org.jboss.javaee.example.ServletSSLTransportExample"/> + <param name="example.classname" value="org.hornetq.javaee.example.ServletSSLTransportExample"/> </antcall> </target> Copied: trunk/examples/javaee/servlet-ssl-example/src/org/hornetq/javaee/example (from rev 7809, trunk/examples/javaee/servlet-ssl-example/src/org/jboss/javaee/example) Modified: trunk/examples/javaee/servlet-ssl-example/src/org/hornetq/javaee/example/ServletSSLTransportExample.java =================================================================== --- trunk/examples/javaee/servlet-ssl-example/src/org/jboss/javaee/example/ServletSSLTransportExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/servlet-ssl-example/src/org/hornetq/javaee/example/ServletSSLTransportExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.javaee.example; +package org.hornetq.javaee.example; import javax.jms.Connection; import javax.jms.ConnectionFactory; Modified: trunk/examples/javaee/servlet-transport/build.xml =================================================================== --- trunk/examples/javaee/servlet-transport/build.xml 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/servlet-transport/build.xml 2009-08-19 23:59:53 UTC (rev 7810) @@ -31,7 +31,7 @@ <target name="run"> <antcall target="runExample"> - <param name="example.classname" value="org.jboss.javaee.example.ServletTransportExample"/> + <param name="example.classname" value="org.hornetq.javaee.example.ServletTransportExample"/> </antcall> </target> Copied: trunk/examples/javaee/servlet-transport/src/org/hornetq/javaee/example (from rev 7809, trunk/examples/javaee/servlet-transport/src/org/jboss/javaee/example) Modified: trunk/examples/javaee/servlet-transport/src/org/hornetq/javaee/example/ServletTransportExample.java =================================================================== --- trunk/examples/javaee/servlet-transport/src/org/jboss/javaee/example/ServletTransportExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/servlet-transport/src/org/hornetq/javaee/example/ServletTransportExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.javaee.example; +package org.hornetq.javaee.example; import javax.jms.Connection; import javax.jms.ConnectionFactory; Modified: trunk/examples/javaee/xarecovery/build.xml =================================================================== --- trunk/examples/javaee/xarecovery/build.xml 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/xarecovery/build.xml 2009-08-19 23:59:53 UTC (rev 7810) @@ -39,7 +39,7 @@ <target name="run"> <antcall target="runExample"> - <param name="example.classname" value="org.jboss.javaee.example.XARecoveryExample"/> + <param name="example.classname" value="org.hornetq.javaee.example.XARecoveryExample"/> </antcall> </target> Copied: trunk/examples/javaee/xarecovery/src/org/hornetq/javaee/example/XARecoveryExample.java (from rev 7809, trunk/examples/javaee/xarecovery/src/org/jboss/javaee/example/XARecoveryExample.java) =================================================================== --- trunk/examples/javaee/xarecovery/src/org/hornetq/javaee/example/XARecoveryExample.java (rev 0) +++ trunk/examples/javaee/xarecovery/src/org/hornetq/javaee/example/XARecoveryExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -0,0 +1,145 @@ +/* + * JBoss, Home of Professional Open Source + * Copyright 2005-2008, Red Hat Middleware LLC, and individual contributors + * by the @authors tag. See the copyright.txt in the distribution for a + * full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package org.hornetq.javaee.example; + +import java.util.Date; + +import javax.jms.Connection; +import javax.jms.ConnectionFactory; +import javax.jms.MessageConsumer; +import javax.jms.Queue; +import javax.jms.Session; +import javax.jms.TextMessage; +import javax.naming.InitialContext; + +import org.hornetq.javaee.example.server.XARecoveryExampleService; + +/** + * An example which invokes an EJB. The EJB will be involved in a + * transaction with a "buggy" XAResource to crash the server. + * When the server is restarted, the recovery manager will recover the message + * so that the consumer can receive it. + * + * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> + * @author <a href="mailto:jmesnil@redhat.com">Jeff Mesnil</a> + */ +public class XARecoveryExample +{ + + public static void main(String[] args) throws Exception + { + InitialContext initialContext = null; + try + { + // Step 1. Obtain an Initial Context + initialContext = new InitialContext(); + + // Step 2. Lookup the EJB + XARecoveryExampleService service = (XARecoveryExampleService)initialContext.lookup("xarecovery-example/XARecoveryExampleBean/remote"); + + // Step 3. Invoke the send method. This will crash the server + String message = "This is a text message sent at " + new Date(); + System.out.println("invoking the EJB service with text: " + message); + try + { + service.send(message); + } + catch (Exception e) + { + System.out.println("#########################"); + System.out.println("The server crashed: " + e.getMessage()); + System.out.println("#########################"); + } + + System.out.println("\n\n\nRestart the server by running 'ant restart' in a terminal"); + + // Step 4. We will try to receive a message. Once the server is restarted, the message + // will be recovered and the consumer will receive it + System.out.println("Waiting for the server to restart and recover before receiving a message"); + + boolean received = false; + while (!received) + { + try + { + Thread.sleep(15000); + receiveMessage(); + received = true; + } + catch (Exception e) + { + System.out.println("."); + } + } + } + finally + { + // Step 4. Be sure to close the resources! + if (initialContext != null) + { + initialContext.close(); + } + } + } + + private static void receiveMessage() throws Exception + { + InitialContext initialContext = null; + Connection connection = null; + try + { + // Step 1. Obtain an Initial Context + initialContext = new InitialContext(); + + // Step 2. Lookup the JMS connection factory + ConnectionFactory cf = (ConnectionFactory)initialContext.lookup("/ConnectionFactory"); + + // Step 3. Lookup the queue + Queue queue = (Queue)initialContext.lookup("queue/testQueue"); + + // Step 4. Create a connection, a session and a message consumer for the queue + connection = cf.createConnection(); + Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); + MessageConsumer consumer = session.createConsumer(queue); + + // Step 5. Start the connection + connection.start(); + + // Step 6. Receive the message sent by the EJB + System.out.println("\nwaiting to receive a message..."); + TextMessage messageReceived = (TextMessage)consumer.receive(3600 * 1000); + System.out.format("Received message: %s \n\t(JMS MessageID: %s)\n", messageReceived.getText(), messageReceived.getJMSMessageID()); + } + finally + { + // Step 7. Be sure to close the resources! + if (initialContext != null) + { + initialContext.close(); + } + if (connection != null) + { + connection.close(); + } + } + } +} Copied: trunk/examples/javaee/xarecovery/src/org/hornetq/javaee/example/server (from rev 7809, trunk/examples/javaee/xarecovery/src/org/jboss/javaee/example/server) Modified: trunk/examples/javaee/xarecovery/src/org/hornetq/javaee/example/server/XARecoveryExampleBean.java =================================================================== --- trunk/examples/javaee/xarecovery/src/org/jboss/javaee/example/server/XARecoveryExampleBean.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/xarecovery/src/org/hornetq/javaee/example/server/XARecoveryExampleBean.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.javaee.example.server; +package org.hornetq.javaee.example.server; import javax.ejb.Remote; import javax.ejb.Stateless; Modified: trunk/examples/javaee/xarecovery/src/org/hornetq/javaee/example/server/XARecoveryExampleService.java =================================================================== --- trunk/examples/javaee/xarecovery/src/org/jboss/javaee/example/server/XARecoveryExampleService.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/xarecovery/src/org/hornetq/javaee/example/server/XARecoveryExampleService.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.javaee.example.server; +package org.hornetq.javaee.example.server; /** * An interface for the XARecoveryExampleBean EJB. Deleted: trunk/examples/javaee/xarecovery/src/org/jboss/javaee/example/XARecoveryExample.java =================================================================== --- trunk/examples/javaee/xarecovery/src/org/jboss/javaee/example/XARecoveryExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/javaee/xarecovery/src/org/jboss/javaee/example/XARecoveryExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -1,145 +0,0 @@ -/* - * JBoss, Home of Professional Open Source - * Copyright 2005-2008, Red Hat Middleware LLC, and individual contributors - * by the @authors tag. See the copyright.txt in the distribution for a - * full listing of individual contributors. - * - * This is free software; you can redistribute it and/or modify it - * under the terms of the GNU Lesser General Public License as - * published by the Free Software Foundation; either version 2.1 of - * the License, or (at your option) any later version. - * - * This software is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this software; if not, write to the Free - * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA - * 02110-1301 USA, or see the FSF site: http://www.fsf.org. - */ -package org.jboss.javaee.example; - -import java.util.Date; - -import javax.jms.Connection; -import javax.jms.ConnectionFactory; -import javax.jms.MessageConsumer; -import javax.jms.Queue; -import javax.jms.Session; -import javax.jms.TextMessage; -import javax.naming.InitialContext; - -import org.jboss.javaee.example.server.XARecoveryExampleService; - -/** - * An example which invokes an EJB. The EJB will be involved in a - * transaction with a "buggy" XAResource to crash the server. - * When the server is restarted, the recovery manager will recover the message - * so that the consumer can receive it. - * - * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> - * @author <a href="mailto:jmesnil@redhat.com">Jeff Mesnil</a> - */ -public class XARecoveryExample -{ - - public static void main(String[] args) throws Exception - { - InitialContext initialContext = null; - try - { - // Step 1. Obtain an Initial Context - initialContext = new InitialContext(); - - // Step 2. Lookup the EJB - XARecoveryExampleService service = (XARecoveryExampleService)initialContext.lookup("xarecovery-example/XARecoveryExampleBean/remote"); - - // Step 3. Invoke the send method. This will crash the server - String message = "This is a text message sent at " + new Date(); - System.out.println("invoking the EJB service with text: " + message); - try - { - service.send(message); - } - catch (Exception e) - { - System.out.println("#########################"); - System.out.println("The server crashed: " + e.getMessage()); - System.out.println("#########################"); - } - - System.out.println("\n\n\nRestart the server by running 'ant restart' in a terminal"); - - // Step 4. We will try to receive a message. Once the server is restarted, the message - // will be recovered and the consumer will receive it - System.out.println("Waiting for the server to restart and recover before receiving a message"); - - boolean received = false; - while (!received) - { - try - { - Thread.sleep(15000); - receiveMessage(); - received = true; - } - catch (Exception e) - { - System.out.println("."); - } - } - } - finally - { - // Step 4. Be sure to close the resources! - if (initialContext != null) - { - initialContext.close(); - } - } - } - - private static void receiveMessage() throws Exception - { - InitialContext initialContext = null; - Connection connection = null; - try - { - // Step 1. Obtain an Initial Context - initialContext = new InitialContext(); - - // Step 2. Lookup the JMS connection factory - ConnectionFactory cf = (ConnectionFactory)initialContext.lookup("/ConnectionFactory"); - - // Step 3. Lookup the queue - Queue queue = (Queue)initialContext.lookup("queue/testQueue"); - - // Step 4. Create a connection, a session and a message consumer for the queue - connection = cf.createConnection(); - Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); - MessageConsumer consumer = session.createConsumer(queue); - - // Step 5. Start the connection - connection.start(); - - // Step 6. Receive the message sent by the EJB - System.out.println("\nwaiting to receive a message..."); - TextMessage messageReceived = (TextMessage)consumer.receive(3600 * 1000); - System.out.format("Received message: %s \n\t(JMS MessageID: %s)\n", messageReceived.getText(), messageReceived.getJMSMessageID()); - } - finally - { - // Step 7. Be sure to close the resources! - if (initialContext != null) - { - initialContext.close(); - } - if (connection != null) - { - connection.close(); - } - } - } -} Copied: trunk/examples/jms/management/src/org/hornetq/jms/example (from rev 7808, trunk/examples/jms/management/src/org/jboss/jms/example) Modified: trunk/examples/jms/management/src/org/hornetq/jms/example/ManagementExample.java =================================================================== --- trunk/examples/jms/management/src/org/jboss/jms/example/ManagementExample.java 2009-08-19 23:31:43 UTC (rev 7808) +++ trunk/examples/jms/management/src/org/hornetq/jms/example/ManagementExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import javax.jms.Message; import javax.jms.MessageConsumer; Copied: trunk/examples/jms/management-notifications/src/org/hornetq/jms/example (from rev 7808, trunk/examples/jms/management-notifications/src/org/jboss/jms/example) Modified: trunk/examples/jms/management-notifications/src/org/hornetq/jms/example/ManagementNotificationExample.java =================================================================== --- trunk/examples/jms/management-notifications/src/org/jboss/jms/example/ManagementNotificationExample.java 2009-08-19 23:31:43 UTC (rev 7808) +++ trunk/examples/jms/management-notifications/src/org/hornetq/jms/example/ManagementNotificationExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import java.util.Enumeration; Copied: trunk/examples/jms/message-counters/src/org/hornetq/jms/example (from rev 7808, trunk/examples/jms/message-counters/src/org/jboss/jms/example) Modified: trunk/examples/jms/message-counters/src/org/hornetq/jms/example/MessageCounterExample.java =================================================================== --- trunk/examples/jms/message-counters/src/org/jboss/jms/example/MessageCounterExample.java 2009-08-19 23:31:43 UTC (rev 7808) +++ trunk/examples/jms/message-counters/src/org/hornetq/jms/example/MessageCounterExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import org.hornetq.common.example.JBMExample; import org.hornetq.core.management.MessageCounterInfo; Copied: trunk/examples/jms/message-group/src/org/hornetq/jms/example (from rev 7808, trunk/examples/jms/message-group/src/org/jboss/jms/example) Modified: trunk/examples/jms/message-group/src/org/hornetq/jms/example/MessageGroupExample.java =================================================================== --- trunk/examples/jms/message-group/src/org/jboss/jms/example/MessageGroupExample.java 2009-08-19 23:31:43 UTC (rev 7808) +++ trunk/examples/jms/message-group/src/org/hornetq/jms/example/MessageGroupExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; Copied: trunk/examples/jms/message-priority/src/org/hornetq/jms/example (from rev 7808, trunk/examples/jms/message-priority/src/org/jboss/jms/example) Modified: trunk/examples/jms/message-priority/src/org/hornetq/jms/example/MessagePriorityExample.java =================================================================== --- trunk/examples/jms/message-priority/src/org/jboss/jms/example/MessagePriorityExample.java 2009-08-19 23:31:43 UTC (rev 7808) +++ trunk/examples/jms/message-priority/src/org/hornetq/jms/example/MessagePriorityExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import java.util.ArrayList; Copied: trunk/examples/jms/no-consumer-buffering/src/org/hornetq/jms/example (from rev 7808, trunk/examples/jms/no-consumer-buffering/src/org/jboss/jms/example) Modified: trunk/examples/jms/no-consumer-buffering/src/org/hornetq/jms/example/NoConsumerBufferingExample.java =================================================================== --- trunk/examples/jms/no-consumer-buffering/src/org/jboss/jms/example/NoConsumerBufferingExample.java 2009-08-19 23:31:43 UTC (rev 7808) +++ trunk/examples/jms/no-consumer-buffering/src/org/hornetq/jms/example/NoConsumerBufferingExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import javax.jms.Connection; import javax.jms.ConnectionFactory; Copied: trunk/examples/jms/paging/src/org/hornetq/jms/example (from rev 7808, trunk/examples/jms/paging/src/org/jboss/jms/example) Modified: trunk/examples/jms/paging/src/org/hornetq/jms/example/PagingExample.java =================================================================== --- trunk/examples/jms/paging/src/org/jboss/jms/example/PagingExample.java 2009-08-19 23:31:43 UTC (rev 7808) +++ trunk/examples/jms/paging/src/org/hornetq/jms/example/PagingExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import org.hornetq.common.example.JBMExample; Copied: trunk/examples/jms/perf/src/org/hornetq/jms/example (from rev 7808, trunk/examples/jms/perf/src/org/jboss/jms/example) Modified: trunk/examples/jms/perf/src/org/hornetq/jms/example/PerfBase.java =================================================================== --- trunk/examples/jms/perf/src/org/jboss/jms/example/PerfBase.java 2009-08-19 23:31:43 UTC (rev 7808) +++ trunk/examples/jms/perf/src/org/hornetq/jms/example/PerfBase.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import java.io.FileInputStream; import java.io.InputStream; Modified: trunk/examples/jms/perf/src/org/hornetq/jms/example/PerfListener.java =================================================================== --- trunk/examples/jms/perf/src/org/jboss/jms/example/PerfListener.java 2009-08-19 23:31:43 UTC (rev 7808) +++ trunk/examples/jms/perf/src/org/hornetq/jms/example/PerfListener.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import java.util.logging.Logger; Modified: trunk/examples/jms/perf/src/org/hornetq/jms/example/PerfParams.java =================================================================== --- trunk/examples/jms/perf/src/org/jboss/jms/example/PerfParams.java 2009-08-19 23:31:43 UTC (rev 7808) +++ trunk/examples/jms/perf/src/org/hornetq/jms/example/PerfParams.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import java.io.Serializable; Modified: trunk/examples/jms/perf/src/org/hornetq/jms/example/PerfSender.java =================================================================== --- trunk/examples/jms/perf/src/org/jboss/jms/example/PerfSender.java 2009-08-19 23:31:43 UTC (rev 7808) +++ trunk/examples/jms/perf/src/org/hornetq/jms/example/PerfSender.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import java.util.logging.Logger; Copied: trunk/examples/jms/pre-acknowledge/src/org/hornetq/jms/example (from rev 7808, trunk/examples/jms/pre-acknowledge/src/org/jboss/jms/example) Modified: trunk/examples/jms/pre-acknowledge/src/org/hornetq/jms/example/PreacknowledgeExample.java =================================================================== --- trunk/examples/jms/pre-acknowledge/src/org/jboss/jms/example/PreacknowledgeExample.java 2009-08-19 23:31:43 UTC (rev 7808) +++ trunk/examples/jms/pre-acknowledge/src/org/hornetq/jms/example/PreacknowledgeExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import javax.jms.Connection; import javax.jms.ConnectionFactory; Copied: trunk/examples/jms/producer-rate-limit/src/org/hornetq/jms/example (from rev 7808, trunk/examples/jms/producer-rate-limit/src/org/jboss/jms/example) Modified: trunk/examples/jms/producer-rate-limit/src/org/hornetq/jms/example/ProducerRateLimitExample.java =================================================================== --- trunk/examples/jms/producer-rate-limit/src/org/jboss/jms/example/ProducerRateLimitExample.java 2009-08-19 23:31:43 UTC (rev 7808) +++ trunk/examples/jms/producer-rate-limit/src/org/hornetq/jms/example/ProducerRateLimitExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import javax.jms.Connection; import javax.jms.ConnectionFactory; Copied: trunk/examples/jms/queue/src/org/hornetq/jms/example (from rev 7808, trunk/examples/jms/queue/src/org/jboss/jms/example) Modified: trunk/examples/jms/queue/src/org/hornetq/jms/example/QueueExample.java =================================================================== --- trunk/examples/jms/queue/src/org/jboss/jms/example/QueueExample.java 2009-08-19 23:31:43 UTC (rev 7808) +++ trunk/examples/jms/queue/src/org/hornetq/jms/example/QueueExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import javax.jms.Connection; import javax.jms.ConnectionFactory; Copied: trunk/examples/jms/queue-message-redistribution/src/org/hornetq/jms/example (from rev 7808, trunk/examples/jms/queue-message-redistribution/src/org/jboss/jms/example) Modified: trunk/examples/jms/queue-message-redistribution/src/org/hornetq/jms/example/QueueMessageRedistributionExample.java =================================================================== --- trunk/examples/jms/queue-message-redistribution/src/org/jboss/jms/example/QueueMessageRedistributionExample.java 2009-08-19 23:31:43 UTC (rev 7808) +++ trunk/examples/jms/queue-message-redistribution/src/org/hornetq/jms/example/QueueMessageRedistributionExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import javax.jms.Connection; import javax.jms.ConnectionFactory; Copied: trunk/examples/jms/queue-requestor/src/org/hornetq/jms/example (from rev 7808, trunk/examples/jms/queue-requestor/src/org/jboss/jms/example) Modified: trunk/examples/jms/queue-requestor/src/org/hornetq/jms/example/QueueRequestorExample.java =================================================================== --- trunk/examples/jms/queue-requestor/src/org/jboss/jms/example/QueueRequestorExample.java 2009-08-19 23:31:43 UTC (rev 7808) +++ trunk/examples/jms/queue-requestor/src/org/hornetq/jms/example/QueueRequestorExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import javax.jms.JMSException; import javax.jms.Queue; Modified: trunk/examples/jms/queue-requestor/src/org/hornetq/jms/example/TextReverserService.java =================================================================== --- trunk/examples/jms/queue-requestor/src/org/jboss/jms/example/TextReverserService.java 2009-08-19 23:31:43 UTC (rev 7808) +++ trunk/examples/jms/queue-requestor/src/org/hornetq/jms/example/TextReverserService.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -20,7 +20,7 @@ * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import javax.jms.Connection; import javax.jms.ConnectionFactory; Copied: trunk/examples/jms/queue-selector/src/org/hornetq/jms/example (from rev 7808, trunk/examples/jms/queue-selector/src/org/jboss/jms/example) Modified: trunk/examples/jms/queue-selector/src/org/hornetq/jms/example/QueueSelectorExample.java =================================================================== --- trunk/examples/jms/queue-selector/src/org/jboss/jms/example/QueueSelectorExample.java 2009-08-19 23:31:43 UTC (rev 7808) +++ trunk/examples/jms/queue-selector/src/org/hornetq/jms/example/QueueSelectorExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import javax.jms.Connection; import javax.jms.ConnectionFactory; Copied: trunk/examples/jms/reconnect-same-node/src/org/hornetq/jms/example (from rev 7808, trunk/examples/jms/reconnect-same-node/src/org/jboss/jms/example) Modified: trunk/examples/jms/reconnect-same-node/src/org/hornetq/jms/example/ReconnectSameNodeExample.java =================================================================== --- trunk/examples/jms/reconnect-same-node/src/org/jboss/jms/example/ReconnectSameNodeExample.java 2009-08-19 23:31:43 UTC (rev 7808) +++ trunk/examples/jms/reconnect-same-node/src/org/hornetq/jms/example/ReconnectSameNodeExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import javax.jms.Connection; import javax.jms.ConnectionFactory; Copied: trunk/examples/jms/request-reply/src/org/hornetq/jms/example (from rev 7809, trunk/examples/jms/request-reply/src/org/jboss/jms/example) Modified: trunk/examples/jms/request-reply/src/org/hornetq/jms/example/RequestReplyExample.java =================================================================== --- trunk/examples/jms/request-reply/src/org/jboss/jms/example/RequestReplyExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/jms/request-reply/src/org/hornetq/jms/example/RequestReplyExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import javax.jms.Connection; import javax.jms.ConnectionFactory; Copied: trunk/examples/jms/scheduled-message/src/org/hornetq/jms/example (from rev 7809, trunk/examples/jms/scheduled-message/src/org/jboss/jms/example) Modified: trunk/examples/jms/scheduled-message/src/org/hornetq/jms/example/ScheduledMessageExample.java =================================================================== --- trunk/examples/jms/scheduled-message/src/org/jboss/jms/example/ScheduledMessageExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/jms/scheduled-message/src/org/hornetq/jms/example/ScheduledMessageExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import java.text.SimpleDateFormat; import java.util.Date; Copied: trunk/examples/jms/security/src/org/hornetq/jms/example (from rev 7809, trunk/examples/jms/security/src/org/jboss/jms/example) Modified: trunk/examples/jms/security/src/org/hornetq/jms/example/SecurityExample.java =================================================================== --- trunk/examples/jms/security/src/org/jboss/jms/example/SecurityExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/jms/security/src/org/hornetq/jms/example/SecurityExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import javax.jms.Connection; import javax.jms.ConnectionFactory; Copied: trunk/examples/jms/send-acknowledgements/src/org/hornetq/jms/example (from rev 7809, trunk/examples/jms/send-acknowledgements/src/org/jboss/jms/example) Modified: trunk/examples/jms/send-acknowledgements/src/org/hornetq/jms/example/SendAcknowledgementsExample.java =================================================================== --- trunk/examples/jms/send-acknowledgements/src/org/jboss/jms/example/SendAcknowledgementsExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/jms/send-acknowledgements/src/org/hornetq/jms/example/SendAcknowledgementsExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import javax.jms.Connection; import javax.jms.ConnectionFactory; Copied: trunk/examples/jms/ssl-enabled/src/org/hornetq/jms/example (from rev 7809, trunk/examples/jms/ssl-enabled/src/org/jboss/jms/example) Modified: trunk/examples/jms/ssl-enabled/src/org/hornetq/jms/example/SSLExample.java =================================================================== --- trunk/examples/jms/ssl-enabled/src/org/jboss/jms/example/SSLExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/jms/ssl-enabled/src/org/hornetq/jms/example/SSLExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import javax.jms.Connection; import javax.jms.ConnectionFactory; Copied: trunk/examples/jms/static-selector/src/org/hornetq/jms/example (from rev 7809, trunk/examples/jms/static-selector/src/org/jboss/jms/example) Modified: trunk/examples/jms/static-selector/src/org/hornetq/jms/example/StaticSelectorExample.java =================================================================== --- trunk/examples/jms/static-selector/src/org/jboss/jms/example/StaticSelectorExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/jms/static-selector/src/org/hornetq/jms/example/StaticSelectorExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import javax.jms.Connection; import javax.jms.ConnectionFactory; Copied: trunk/examples/jms/static-selector-jms/src/org/hornetq/jms/example (from rev 7809, trunk/examples/jms/static-selector-jms/src/org/jboss/jms/example) Modified: trunk/examples/jms/static-selector-jms/src/org/hornetq/jms/example/StaticSelectorJMSExample.java =================================================================== --- trunk/examples/jms/static-selector-jms/src/org/jboss/jms/example/StaticSelectorJMSExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/jms/static-selector-jms/src/org/hornetq/jms/example/StaticSelectorJMSExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import javax.jms.Connection; import javax.jms.ConnectionFactory; Copied: trunk/examples/jms/symmetric-cluster/src/org/hornetq/jms/example (from rev 7809, trunk/examples/jms/symmetric-cluster/src/org/jboss/jms/example) Modified: trunk/examples/jms/symmetric-cluster/src/org/hornetq/jms/example/SymmetricClusterExample.java =================================================================== --- trunk/examples/jms/symmetric-cluster/src/org/jboss/jms/example/SymmetricClusterExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/jms/symmetric-cluster/src/org/hornetq/jms/example/SymmetricClusterExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import org.hornetq.common.example.JBMExample; import org.hornetq.jms.JBossQueue; Copied: trunk/examples/jms/temp-queue/src/org/hornetq/jms/example (from rev 7809, trunk/examples/jms/temp-queue/src/org/jboss/jms/example) Modified: trunk/examples/jms/temp-queue/src/org/hornetq/jms/example/TemporaryQueueExample.java =================================================================== --- trunk/examples/jms/temp-queue/src/org/jboss/jms/example/TemporaryQueueExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/jms/temp-queue/src/org/hornetq/jms/example/TemporaryQueueExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import javax.jms.Connection; import javax.jms.ConnectionFactory; Copied: trunk/examples/jms/topic/src/org/hornetq/jms/example (from rev 7809, trunk/examples/jms/topic/src/org/jboss/jms/example) Modified: trunk/examples/jms/topic/src/org/hornetq/jms/example/TopicExample.java =================================================================== --- trunk/examples/jms/topic/src/org/jboss/jms/example/TopicExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/jms/topic/src/org/hornetq/jms/example/TopicExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import javax.jms.Connection; import javax.jms.ConnectionFactory; Copied: trunk/examples/jms/topic-hierarchies/src/org/hornetq/jms/example (from rev 7809, trunk/examples/jms/topic-hierarchies/src/org/jboss/jms/example) Modified: trunk/examples/jms/topic-hierarchies/src/org/hornetq/jms/example/TopicHierarchyExample.java =================================================================== --- trunk/examples/jms/topic-hierarchies/src/org/jboss/jms/example/TopicHierarchyExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/jms/topic-hierarchies/src/org/hornetq/jms/example/TopicHierarchyExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import javax.jms.Connection; import javax.jms.ConnectionFactory; Copied: trunk/examples/jms/topic-selector-example1/src/org/hornetq/jms/example (from rev 7809, trunk/examples/jms/topic-selector-example1/src/org/jboss/jms/example) Modified: trunk/examples/jms/topic-selector-example1/src/org/hornetq/jms/example/TopicSelectorExample1.java =================================================================== --- trunk/examples/jms/topic-selector-example1/src/org/jboss/jms/example/TopicSelectorExample1.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/jms/topic-selector-example1/src/org/hornetq/jms/example/TopicSelectorExample1.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import javax.jms.Connection; import javax.jms.ConnectionFactory; Copied: trunk/examples/jms/topic-selector-example2/src/org/hornetq/jms/example (from rev 7809, trunk/examples/jms/topic-selector-example2/src/org/jboss/jms/example) Modified: trunk/examples/jms/topic-selector-example2/src/org/hornetq/jms/example/TopicSelectorExample2.java =================================================================== --- trunk/examples/jms/topic-selector-example2/src/org/jboss/jms/example/TopicSelectorExample2.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/jms/topic-selector-example2/src/org/hornetq/jms/example/TopicSelectorExample2.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import javax.jms.Connection; import javax.jms.ConnectionFactory; Copied: trunk/examples/jms/transactional/src/org/hornetq/jms/example (from rev 7809, trunk/examples/jms/transactional/src/org/jboss/jms/example) Modified: trunk/examples/jms/transactional/src/org/hornetq/jms/example/TransactionalExample.java =================================================================== --- trunk/examples/jms/transactional/src/org/jboss/jms/example/TransactionalExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/jms/transactional/src/org/hornetq/jms/example/TransactionalExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import javax.jms.Connection; import javax.jms.ConnectionFactory; Copied: trunk/examples/jms/xa-heuristic/src/org/hornetq/jms/example (from rev 7809, trunk/examples/jms/xa-heuristic/src/org/jboss/jms/example) Modified: trunk/examples/jms/xa-heuristic/src/org/hornetq/jms/example/XAHeuristicExample.java =================================================================== --- trunk/examples/jms/xa-heuristic/src/org/jboss/jms/example/XAHeuristicExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/jms/xa-heuristic/src/org/hornetq/jms/example/XAHeuristicExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import org.hornetq.common.example.DummyXid; import org.hornetq.common.example.JBMExample; Copied: trunk/examples/jms/xa-receive/src/org/hornetq/jms/example (from rev 7809, trunk/examples/jms/xa-receive/src/org/jboss/jms/example) Modified: trunk/examples/jms/xa-receive/src/org/hornetq/jms/example/XAReceiveExample.java =================================================================== --- trunk/examples/jms/xa-receive/src/org/jboss/jms/example/XAReceiveExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/jms/xa-receive/src/org/hornetq/jms/example/XAReceiveExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import org.hornetq.common.example.DummyXid; import org.hornetq.common.example.JBMExample; Copied: trunk/examples/jms/xa-send/src/org/hornetq/jms/example (from rev 7809, trunk/examples/jms/xa-send/src/org/jboss/jms/example) Modified: trunk/examples/jms/xa-send/src/org/hornetq/jms/example/XASendExample.java =================================================================== --- trunk/examples/jms/xa-send/src/org/jboss/jms/example/XASendExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/jms/xa-send/src/org/hornetq/jms/example/XASendExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import org.hornetq.common.example.DummyXid; import org.hornetq.common.example.JBMExample; Copied: trunk/examples/jms/xa-with-jta/src/org/hornetq/jms/example (from rev 7809, trunk/examples/jms/xa-with-jta/src/org/jboss/jms/example) Modified: trunk/examples/jms/xa-with-jta/src/org/hornetq/jms/example/XAwithJTAExample.java =================================================================== --- trunk/examples/jms/xa-with-jta/src/org/jboss/jms/example/XAwithJTAExample.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/jms/xa-with-jta/src/org/hornetq/jms/example/XAwithJTAExample.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.example; +package org.hornetq.jms.example; import javax.jms.MessageConsumer; import javax.jms.MessageProducer; Modified: trunk/examples/soak/normal/build.xml =================================================================== --- trunk/examples/soak/normal/build.xml 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/soak/normal/build.xml 2009-08-19 23:59:53 UTC (rev 7810) @@ -51,7 +51,7 @@ <target name="runSender" depends="compile"> <property name="jndi.url" value="jnp://${jndi.address}:${jndi.port}" /> - <java classname="org.jboss.jms.soak.example.SoakSender" fork="true" resultproperty="example-result"> + <java classname="org.hornetq.jms.soak.example.SoakSender" fork="true" resultproperty="example-result"> <jvmarg value="-Xms512M" /> <jvmarg value="-Xmx512M" /> <jvmarg value="-XX:+UseParallelGC" /> @@ -69,7 +69,7 @@ <target name="runReceiver" depends="compile"> <property name="jndi.url" value="jnp://${jndi.address}:${jndi.port}" /> - <java classname="org.jboss.jms.soak.example.SoakReceiver" fork="true" resultproperty="example-result"> + <java classname="org.hornetq.jms.soak.example.SoakReceiver" fork="true" resultproperty="example-result"> <jvmarg value="-Xms512M" /> <jvmarg value="-Xmx512M" /> <jvmarg value="-XX:+UseParallelGC" /> Copied: trunk/examples/soak/normal/src/org/hornetq/jms/soak/example (from rev 7809, trunk/examples/soak/normal/src/org/jboss/jms/soak/example) Modified: trunk/examples/soak/normal/src/org/hornetq/jms/soak/example/SoakBase.java =================================================================== --- trunk/examples/soak/normal/src/org/jboss/jms/soak/example/SoakBase.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/soak/normal/src/org/hornetq/jms/soak/example/SoakBase.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.soak.example; +package org.hornetq.jms.soak.example; import java.io.FileInputStream; import java.io.InputStream; Modified: trunk/examples/soak/normal/src/org/hornetq/jms/soak/example/SoakParams.java =================================================================== --- trunk/examples/soak/normal/src/org/jboss/jms/soak/example/SoakParams.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/soak/normal/src/org/hornetq/jms/soak/example/SoakParams.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.soak.example; +package org.hornetq.jms.soak.example; import java.io.Serializable; Modified: trunk/examples/soak/normal/src/org/hornetq/jms/soak/example/SoakReceiver.java =================================================================== --- trunk/examples/soak/normal/src/org/jboss/jms/soak/example/SoakReceiver.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/soak/normal/src/org/hornetq/jms/soak/example/SoakReceiver.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.soak.example; +package org.hornetq.jms.soak.example; import java.util.Hashtable; import java.util.UUID; Modified: trunk/examples/soak/normal/src/org/hornetq/jms/soak/example/SoakSender.java =================================================================== --- trunk/examples/soak/normal/src/org/jboss/jms/soak/example/SoakSender.java 2009-08-19 23:43:43 UTC (rev 7809) +++ trunk/examples/soak/normal/src/org/hornetq/jms/soak/example/SoakSender.java 2009-08-19 23:59:53 UTC (rev 7810) @@ -19,7 +19,7 @@ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA * 02110-1301 USA, or see the FSF site: http://www.fsf.org. */ -package org.jboss.jms.soak.example; +package org.hornetq.jms.soak.example; import java.util.Hashtable; import java.util.concurrent.atomic.AtomicLong;