You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sm...@apache.org on 2011/07/03 17:51:46 UTC
svn commit: r1142453 [1/12] - in
/incubator/airavata/ws-messaging/trunk/messagebroker: ./ .settings/
customLibs/ customLibs/activeMQ/ src/ src/main/ src/main/java/
src/main/java/org/ src/main/java/org/apache/
src/main/java/org/apache/airavata/ src/main...
Author: smarru
Date: Sun Jul 3 15:51:36 2011
New Revision: 1142453
URL: http://svn.apache.org/viewvc?rev=1142453&view=rev
Log:
cleaned up message broker
Added:
incubator/airavata/ws-messaging/trunk/messagebroker/
incubator/airavata/ws-messaging/trunk/messagebroker/.classpath
incubator/airavata/ws-messaging/trunk/messagebroker/.project
incubator/airavata/ws-messaging/trunk/messagebroker/.settings/
incubator/airavata/ws-messaging/trunk/messagebroker/.settings/org.eclipse.jdt.core.prefs
incubator/airavata/ws-messaging/trunk/messagebroker/.settings/org.maven.ide.eclipse.prefs
incubator/airavata/ws-messaging/trunk/messagebroker/customLibs/
incubator/airavata/ws-messaging/trunk/messagebroker/customLibs/activeMQ/
incubator/airavata/ws-messaging/trunk/messagebroker/customLibs/activeMQ/amq.jar (with props)
incubator/airavata/ws-messaging/trunk/messagebroker/customLibs/activeMQ/geronimo-spec-jms-1.1-rc4.jar (with props)
incubator/airavata/ws-messaging/trunk/messagebroker/customLibs/util-concurrent.jar (with props)
incubator/airavata/ws-messaging/trunk/messagebroker/customLibs/zFilter.jar (with props)
incubator/airavata/ws-messaging/trunk/messagebroker/pom.xml
incubator/airavata/ws-messaging/trunk/messagebroker/src/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/NotificationHandler.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/AbstractBrokerMsgReceiver.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/AdditionalMessageContent.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/BrokerServiceLifeCycle.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/ConsumerInfo.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/ConsumerList.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/ConsumerListManager.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/NotificationProcessor.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/context/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/context/ContextFactory.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/context/ContextParameterInfo.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/context/ContextParameters.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/context/ProcessingContext.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/context/ProcessingContextBuilder.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/context/ProcessingContextFactory.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/handler/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/handler/PublishedMessageHandler.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/subscription/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/subscription/CleanupThread.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/subscription/PublisherRegistrationManager.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/subscription/SubscriptionEntry.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/subscription/SubscriptionManager.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/subscription/SubscriptionState.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/wseventing/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/wseventing/WSEProcessingContextBuilder.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/wseventing/WSEProtocolSupport.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/wseventing/WSEventingMsgReceiver.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/wseventing/WSEventingPublishMsgReceiver.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/wsnotification/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/wsnotification/WSNTProtocolSupport.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/wsnotification/WSNotificationMsgReceiver.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/wsnotification/WSNotificationProcessingContextBuilder.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/client/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/client/CommonClientProcessing.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/client/ConsumerMsgReceiver.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/client/ConsumerNotificationHandler.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/client/ConsumerServer.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/client/ConsumerServerHandler.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/client/ConsumerService.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/client/MessageBrokerClient.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/client/MsgBrokerClientException.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/client/NotificationHandler.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/client/NotificationProducerStub.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/client/SubscriptionInfo.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/client/SubscriptionStub.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/client/WidgetStub.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/client/WseClientAPI.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/client/WseCreateSubscription.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/client/WseMsgBrokerClient.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/client/WsmgClientAPI.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/client/WsntClientAPI.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/client/WsntCreatePublishReg.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/client/WsntMsgBrokerClient.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/client/WsrfResourceStub.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/client/msgbox/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/client/msgbox/MessagePuller.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/client/msgbox/MsgboxHandler.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/commons/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/commons/CommonRoutines.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/commons/NotificationProducer.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/commons/OutGoingMessage.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/commons/WsmgCommonConstants.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/commons/WsmgNameSpaceConstants.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/commons/WsmgVersion.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/commons/XMLConstants.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/commons/exceptions/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/commons/exceptions/XMLComparisonException.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/commons/storage/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/commons/storage/ConnectionPool.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/commons/storage/JdbcStorage.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/commons/storage/KeyValueWrapper.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/commons/storage/WsmgInMemoryStorage.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/commons/storage/WsmgPersistantStorage.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/commons/storage/WsmgStorage.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/commons/util/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/commons/util/OMElementComparator.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/config/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/config/Configuration.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/config/ConfigurationManager.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/config/ConfigurationParamsReader.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/config/WSMGParameter.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/config/WsmgConfigurationContext.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/gui/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/gui/NotificationViewer.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/gui/NotificationViewerFrame.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/gui/README.txt
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/gui/WsntViewerConsumerNotificationHandler.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/matching/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/matching/AbstractMessageMatcher.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/matching/XPath/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/matching/XPath/BitSetUtil.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/matching/XPath/YFilterInfo.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/matching/XPath/YFilterMessageMatcher.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/matching/XPath/util/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/matching/XPath/util/BitSetUtil.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/matching/simpleTopic/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/matching/simpleTopic/DirectWsntMessageMatcher.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/messenger/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/messenger/ConsumerUrlManager.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/messenger/OutGoingQueue.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/messenger/SenderUtils.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/messenger/protocol/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/messenger/protocol/Axis2Protocol.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/messenger/protocol/DeliveryProtocol.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/messenger/protocol/SendingException.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/messenger/strategy/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/messenger/strategy/SendingStrategy.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/messenger/strategy/impl/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/messenger/strategy/impl/FixedParallelSender.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/messenger/strategy/impl/LightweightMsg.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/messenger/strategy/impl/ParallelSender.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/messenger/strategy/impl/SerialSender.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/messenger/strategy/impl/ThreadCrew.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/processors/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/processors/OutGoingMessage.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/processors/PublisherRegistrationManager.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/processors/ReceivedMessage.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/transports/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/transports/jms/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/transports/jms/MessageMatcherConnection.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/util/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/util/Counter.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/util/CurrentDate.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/util/DcDate.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/util/LoadConfigProperties.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/util/RunTimeStatistics.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/util/TimerThread.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/util/WsEventingOperations.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/util/WsNotificationOperations.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/util/WsmgUtil.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/util/test/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/util/test/TestUtilServer.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/resources/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/resources/addressing-1.5.mar (with props)
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/resources/database_scripts/
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/resources/database_scripts/cleanDBScript.sql (with props)
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/resources/database_scripts/mysqlCreationScript.sql (with props)
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/resources/log4j.properties.txt
incubator/airavata/ws-messaging/trunk/messagebroker/src/main/resources/services.xml
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers-topics/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers-topics/README.txt
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers-topics/build.properties
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers-topics/build.xml
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers-topics/conf/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers-topics/conf/configurations.properties
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers-topics/src/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers-topics/src/wsmg/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers-topics/src/wsmg/samples/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers-topics/src/wsmg/samples/util/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers-topics/src/wsmg/samples/util/ConfigKeys.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers-topics/src/wsmg/samples/wse/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers-topics/src/wsmg/samples/wse/Consumer.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers-topics/src/wsmg/samples/wse/MsgUtil.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers-topics/src/wsmg/samples/wse/MultipleProducersConsumersTopics.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers-topics/src/wsmg/samples/wse/Producer.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers-xpath/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers-xpath/README.txt
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers-xpath/build.properties
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers-xpath/build.xml
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers-xpath/conf/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers-xpath/conf/configurations.properties
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers-xpath/src/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers-xpath/src/wsmg/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers-xpath/src/wsmg/samples/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers-xpath/src/wsmg/samples/util/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers-xpath/src/wsmg/samples/util/ConfigKeys.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers-xpath/src/wsmg/samples/wse/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers-xpath/src/wsmg/samples/wse/Consumer.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers-xpath/src/wsmg/samples/wse/MultipleProducersConsumers.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers-xpath/src/wsmg/samples/wse/Producer.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers/README.txt
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers/build.properties
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers/build.xml
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers/conf/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers/conf/configurations.properties
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers/src/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers/src/wsmg/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers/src/wsmg/samples/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers/src/wsmg/samples/util/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers/src/wsmg/samples/util/ConfigKeys.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers/src/wsmg/samples/wse/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers/src/wsmg/samples/wse/Consumer.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers/src/wsmg/samples/wse/MultipleProducersConsumers.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-multiple-producers-consumers/src/wsmg/samples/wse/Producer.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-round-trip/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-round-trip/README.txt
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-round-trip/build.properties
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-round-trip/build.xml
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-round-trip/conf/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-round-trip/conf/configurations.properties
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-round-trip/src/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-round-trip/src/wsmg/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-round-trip/src/wsmg/samples/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-round-trip/src/wsmg/samples/util/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-round-trip/src/wsmg/samples/util/ConfigKeys.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-round-trip/src/wsmg/samples/wse/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-round-trip/src/wsmg/samples/wse/Consumer.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-round-trip/src/wsmg/samples/wse/Producer.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-round-trip/src/wsmg/samples/wse/WSERoundTrip.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-topic-subscription/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-topic-subscription/README.txt
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-topic-subscription/build.properties
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-topic-subscription/build.xml
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-topic-subscription/conf/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-topic-subscription/conf/configurations.properties
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-topic-subscription/src/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-topic-subscription/src/wsmg/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-topic-subscription/src/wsmg/samples/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-topic-subscription/src/wsmg/samples/util/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-topic-subscription/src/wsmg/samples/util/ConfigKeys.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-topic-subscription/src/wsmg/samples/wse/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-topic-subscription/src/wsmg/samples/wse/TopicSubscribe.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-xpath-subscription/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-xpath-subscription/README.txt
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-xpath-subscription/build.properties
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-xpath-subscription/build.xml
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-xpath-subscription/conf/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-xpath-subscription/conf/configurations.properties
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-xpath-subscription/src/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-xpath-subscription/src/wsmg/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-xpath-subscription/src/wsmg/samples/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-xpath-subscription/src/wsmg/samples/util/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-xpath-subscription/src/wsmg/samples/util/ConfigKeys.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-xpath-subscription/src/wsmg/samples/wse/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wse-xpath-subscription/src/wsmg/samples/wse/XpathSubscribe.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wsmg-gui/
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wsmg-gui/README.txt
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wsmg-gui/build.properties
incubator/airavata/ws-messaging/trunk/messagebroker/src/samples/wsmg-gui/build.xml
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/performance_evaluator/
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/performance_evaluator/rtt/
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/performance_evaluator/rtt/NotificationManager.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/performance_evaluator/rtt/PerformanceTest.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/performance_evaluator/rtt/PublisherThread.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/performance_evaluator/rtt/StatCalculatorThread.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/performance_evaluator/rtt/StatContainer.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/performance_evaluator/rtt/Subscription.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/performance_evaluator/rtt/util/
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/performance_evaluator/rtt/util/ConfigKeys.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/performance_evaluator/rtt/util/LoadMsgPayload.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/performance_evaluator/rtt/util/LoadXpath.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/wsmg/
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/wsmg/broker/
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/wsmg/broker/BrokerWSETest.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/wsmg/broker/BrokerWSNTTest.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/wsmg/client/
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/wsmg/client/TestWseMsgBrokerClient.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/wsmg/client/TestWsntMsgBrokerClient.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/wsmg/client/WseClientAPIConsumerTest.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/wsmg/client/WseClientAPIPublishTest.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/wsmg/client/WseClientAPIRoundTripTests.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/wsmg/client/WseClientAPISubscriptionsTest.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/wsmg/client/WseClientAPITest.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/wsmg/client/WsntClientAPIConsumerTest.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/wsmg/client/WsntClientAPIPublishTest.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/wsmg/client/WsntClientAPIRoundTripTests.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/wsmg/client/WsntClientAPISubscriptionTests.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/wsmg/commons/
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/wsmg/commons/TestCommonRoutines.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/wsmg/gui/
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/wsmg/gui/GUITest.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/wsmg/matching/
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/wsmg/matching/XPath/
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/wsmg/matching/XPath/TestAddtionalWseXpathAndTopicScenarios.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/wsmg/matching/XPath/TestWseXpathAndTopicSubscription.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/wsmg/matching/XPath/TestWseXpathSubscription.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/wsmg/matching/XPath/performance/
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/wsmg/matching/XPath/performance/XppXPath.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/wsmg/util/
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/wsmg/util/ConfigKeys.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/wsmg/util/TestDcDate.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/java/wsmg/util/TestWsmgUtil.java
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/resources/
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/resources/unit_tests.properties
incubator/airavata/ws-messaging/trunk/messagebroker/src/test/resources/wsmg.broker.properties
Added: incubator/airavata/ws-messaging/trunk/messagebroker/.classpath
URL: http://svn.apache.org/viewvc/incubator/airavata/ws-messaging/trunk/messagebroker/.classpath?rev=1142453&view=auto
==============================================================================
--- incubator/airavata/ws-messaging/trunk/messagebroker/.classpath (added)
+++ incubator/airavata/ws-messaging/trunk/messagebroker/.classpath Sun Jul 3 15:51:36 2011
@@ -0,0 +1,10 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<classpath>
+ <classpathentry kind="src" output="target/classes" path="src/main/java"/>
+ <classpathentry excluding="**" kind="src" output="target/classes" path="src/main/resources"/>
+ <classpathentry kind="src" output="target/test-classes" path="src/test/java"/>
+ <classpathentry excluding="**" kind="src" output="target/test-classes" path="src/test/resources"/>
+ <classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/J2SE-1.5"/>
+ <classpathentry kind="con" path="org.maven.ide.eclipse.MAVEN2_CLASSPATH_CONTAINER"/>
+ <classpathentry kind="output" path="target/classes"/>
+</classpath>
Added: incubator/airavata/ws-messaging/trunk/messagebroker/.project
URL: http://svn.apache.org/viewvc/incubator/airavata/ws-messaging/trunk/messagebroker/.project?rev=1142453&view=auto
==============================================================================
--- incubator/airavata/ws-messaging/trunk/messagebroker/.project (added)
+++ incubator/airavata/ws-messaging/trunk/messagebroker/.project Sun Jul 3 15:51:36 2011
@@ -0,0 +1,19 @@
+<projectDescription>
+ <name>Message Broker</name>
+ <comment/>
+ <projects>
+ <project>Airavata Messenger</project>
+ </projects>
+ <buildSpec>
+ <buildCommand>
+ <name>org.eclipse.jdt.core.javabuilder</name>
+ </buildCommand>
+ <buildCommand>
+ <name>org.maven.ide.eclipse.maven2Builder</name>
+ </buildCommand>
+ </buildSpec>
+ <natures>
+ <nature>org.eclipse.jdt.core.javanature</nature>
+ <nature>org.maven.ide.eclipse.maven2Nature</nature>
+ </natures>
+</projectDescription>
Added: incubator/airavata/ws-messaging/trunk/messagebroker/.settings/org.eclipse.jdt.core.prefs
URL: http://svn.apache.org/viewvc/incubator/airavata/ws-messaging/trunk/messagebroker/.settings/org.eclipse.jdt.core.prefs?rev=1142453&view=auto
==============================================================================
--- incubator/airavata/ws-messaging/trunk/messagebroker/.settings/org.eclipse.jdt.core.prefs (added)
+++ incubator/airavata/ws-messaging/trunk/messagebroker/.settings/org.eclipse.jdt.core.prefs Sun Jul 3 15:51:36 2011
@@ -0,0 +1,13 @@
+#Sun Jul 03 11:03:32 EDT 2011
+eclipse.preferences.version=1
+org.eclipse.jdt.core.compiler.codegen.inlineJsrBytecode=enabled
+org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.5
+org.eclipse.jdt.core.compiler.codegen.unusedLocal=preserve
+org.eclipse.jdt.core.compiler.compliance=1.5
+org.eclipse.jdt.core.compiler.debug.lineNumber=generate
+org.eclipse.jdt.core.compiler.debug.localVariable=generate
+org.eclipse.jdt.core.compiler.debug.sourceFile=generate
+org.eclipse.jdt.core.compiler.problem.assertIdentifier=error
+org.eclipse.jdt.core.compiler.problem.enumIdentifier=error
+org.eclipse.jdt.core.compiler.problem.forbiddenReference=warning
+org.eclipse.jdt.core.compiler.source=1.5
Added: incubator/airavata/ws-messaging/trunk/messagebroker/.settings/org.maven.ide.eclipse.prefs
URL: http://svn.apache.org/viewvc/incubator/airavata/ws-messaging/trunk/messagebroker/.settings/org.maven.ide.eclipse.prefs?rev=1142453&view=auto
==============================================================================
--- incubator/airavata/ws-messaging/trunk/messagebroker/.settings/org.maven.ide.eclipse.prefs (added)
+++ incubator/airavata/ws-messaging/trunk/messagebroker/.settings/org.maven.ide.eclipse.prefs Sun Jul 3 15:51:36 2011
@@ -0,0 +1,9 @@
+#Tue Aug 18 22:42:48 IST 2009
+activeProfiles=
+eclipse.preferences.version=1
+fullBuildGoals=process-test-resources
+includeModules=false
+resolveWorkspaceProjects=true
+resourceFilterGoals=process-resources resources\:testResources
+skipCompilerPlugin=true
+version=1
Added: incubator/airavata/ws-messaging/trunk/messagebroker/customLibs/activeMQ/amq.jar
URL: http://svn.apache.org/viewvc/incubator/airavata/ws-messaging/trunk/messagebroker/customLibs/activeMQ/amq.jar?rev=1142453&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/airavata/ws-messaging/trunk/messagebroker/customLibs/activeMQ/amq.jar
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/airavata/ws-messaging/trunk/messagebroker/customLibs/activeMQ/geronimo-spec-jms-1.1-rc4.jar
URL: http://svn.apache.org/viewvc/incubator/airavata/ws-messaging/trunk/messagebroker/customLibs/activeMQ/geronimo-spec-jms-1.1-rc4.jar?rev=1142453&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/airavata/ws-messaging/trunk/messagebroker/customLibs/activeMQ/geronimo-spec-jms-1.1-rc4.jar
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/airavata/ws-messaging/trunk/messagebroker/customLibs/util-concurrent.jar
URL: http://svn.apache.org/viewvc/incubator/airavata/ws-messaging/trunk/messagebroker/customLibs/util-concurrent.jar?rev=1142453&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/airavata/ws-messaging/trunk/messagebroker/customLibs/util-concurrent.jar
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/airavata/ws-messaging/trunk/messagebroker/customLibs/zFilter.jar
URL: http://svn.apache.org/viewvc/incubator/airavata/ws-messaging/trunk/messagebroker/customLibs/zFilter.jar?rev=1142453&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/airavata/ws-messaging/trunk/messagebroker/customLibs/zFilter.jar
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/airavata/ws-messaging/trunk/messagebroker/pom.xml
URL: http://svn.apache.org/viewvc/incubator/airavata/ws-messaging/trunk/messagebroker/pom.xml?rev=1142453&view=auto
==============================================================================
--- incubator/airavata/ws-messaging/trunk/messagebroker/pom.xml (added)
+++ incubator/airavata/ws-messaging/trunk/messagebroker/pom.xml Sun Jul 3 15:51:36 2011
@@ -0,0 +1,200 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+
+ <parent>
+ <artifactId>ws-messenger</artifactId>
+ <groupId>Airavata</groupId>
+ <version>0.0.1-SNAPSHOT</version>
+ </parent>
+ <modelVersion>4.0.0</modelVersion>
+ <groupId>Airavata</groupId>
+ <artifactId>messagebroker</artifactId>
+ <name>Message Broker</name>
+ <url>http://incubator.apache.org/airavata/</url>
+ <packaging>jar</packaging>
+ <build>
+
+ <plugins>
+
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-jar-plugin</artifactId>
+ <configuration>
+ <archive>
+ <manifest>
+ <addClasspath>true</addClasspath>
+ <mainClass>org.apache.airavata.wsmg.gui.NotificationViewer</mainClass>
+ </manifest>
+ </archive>
+ </configuration>
+ </plugin>
+
+ <plugin>
+ <groupId>org.apache.axis2</groupId>
+ <artifactId>axis2-aar-maven-plugin</artifactId>
+ <version>1.5</version>
+ <configuration>
+ <servicesXmlFile>src/main/resources/services.xml</servicesXmlFile>
+ <!--wsdlFile>src/main/resources/services.wsdl</wsdlFile-->
+
+ <fileSets>
+ <fileSet>
+ <directory>customLibs</directory>
+ <outputDirectory>lib/</outputDirectory>
+ <includes>
+ <include>*.jar</include>
+ </includes>
+ </fileSet>
+ <fileSet>
+ <directory>customLibs/activeMQ</directory>
+ <outputDirectory>lib/</outputDirectory>
+ <includes>
+ <include>*.jar</include>
+ </includes>
+ </fileSet>
+ </fileSets>
+
+ </configuration>
+ <executions>
+ <execution>
+ <id>createAAR</id>
+ <phase>package</phase>
+ <goals>
+ <goal>aar</goal>
+ </goals>
+ </execution>
+ </executions>
+
+ </plugin>
+ </plugins>
+ </build>
+ <repositories>
+ <repository>
+ <id>ibiblio</id>
+ <name>ibiblio Repository</name>
+ <url>http://mirrors.ibiblio.org/pub/mirrors/maven2
+ </url>
+ </repository>
+
+ <repository>
+ <id> maven 2 java.net</id>
+ <name>2 java.net Maven Repository</name>
+ <url>http://download.java.net/maven/2/
+ </url>
+ <layout>default</layout>
+ </repository>
+ <repository>
+ <id>maven 1 java.net</id>
+ <name>java net maven 1 repo</name>
+ <url>http://download.java.net/maven/1</url>
+ <layout>legacy</layout>
+ <snapshots>
+ <enabled>false</enabled>
+ </snapshots>
+ </repository>
+
+
+ </repositories>
+
+ <dependencies>
+ <dependency>
+ <groupId>junit</groupId>
+ <artifactId>junit</artifactId>
+ <version>4.7</version>
+ <scope>test</scope>
+ </dependency>
+
+ <dependency>
+ <groupId>openjms</groupId>
+ <artifactId>openjms</artifactId>
+ <version>0.7.6</version>
+ </dependency>
+
+ <dependency>
+ <groupId>activeio</groupId>
+ <artifactId>activeio</artifactId>
+ <version>2.1</version>
+ </dependency>
+
+ <dependency>
+ <groupId>amq</groupId>
+ <artifactId>amq</artifactId>
+ <version>1.0</version>
+ <scope>system</scope>
+ <systemPath>${project.basedir}/customLibs/activeMQ/amq.jar</systemPath>
+ </dependency>
+
+ <dependency>
+ <groupId>zfilter</groupId>
+ <artifactId>zFilter</artifactId>
+ <version>1.0</version>
+ <scope>system</scope>
+ <systemPath>${project.basedir}/customLibs/zFilter.jar</systemPath>
+ </dependency>
+
+ <dependency>
+ <groupId>util-concurrent</groupId>
+ <artifactId>util-concurrent</artifactId>
+ <version>1.0</version>
+ <scope>system</scope>
+ <systemPath>${project.basedir}/customLibs/util-concurrent.jar</systemPath>
+ </dependency>
+
+
+ <dependency>
+ <groupId>wsdl4j</groupId>
+ <artifactId>wsdl4j</artifactId>
+ <version>1.5.2</version>
+ </dependency>
+
+ <dependency>
+ <groupId>javax.servlet</groupId>
+ <artifactId>servlet-api</artifactId>
+ <version>2.3</version>
+ <type>jar</type>
+ <scope>compile</scope>
+ </dependency>
+ <dependency>
+ <groupId>wsdl4j</groupId>
+ <artifactId>wsdl4j</artifactId>
+ <version>1.4</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.axis2</groupId>
+ <artifactId>axis2</artifactId>
+ <version>1.5</version>
+ <scope>compile</scope>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.axis2</groupId>
+ <artifactId>axis2-transport-http</artifactId>
+ <version>1.5</version>
+ <scope>compile</scope>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.axis2</groupId>
+ <artifactId>axis2-transport-local</artifactId>
+ <version>1.5</version>
+ <scope>compile</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.ogce.msgbox</groupId>
+ <artifactId>msgbox</artifactId>
+ <version>1.1.1</version>
+ <scope>provided</scope>
+ </dependency>
+
+ <dependency>
+ <groupId>mysql</groupId>
+ <artifactId>mysql-connector-java</artifactId>
+ <version>5.1.6</version>
+ </dependency>
+
+ </dependencies>
+ <properties>
+ <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+ <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
+ </properties>
+</project>
Added: incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/NotificationHandler.java
URL: http://svn.apache.org/viewvc/incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/NotificationHandler.java?rev=1142453&view=auto
==============================================================================
--- incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/NotificationHandler.java (added)
+++ incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/NotificationHandler.java Sun Jul 3 15:51:36 2011
@@ -0,0 +1,26 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+
+package org.apache.airavata.wsmg;
+
+public interface NotificationHandler {
+ public void handleNotification(String message);
+}
Added: incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/AbstractBrokerMsgReceiver.java
URL: http://svn.apache.org/viewvc/incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/AbstractBrokerMsgReceiver.java?rev=1142453&view=auto
==============================================================================
--- incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/AbstractBrokerMsgReceiver.java (added)
+++ incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/AbstractBrokerMsgReceiver.java Sun Jul 3 15:51:36 2011
@@ -0,0 +1,105 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+
+package org.apache.airavata.wsmg.broker;
+
+import java.util.List;
+
+import org.apache.airavata.wsmg.broker.context.ProcessingContext;
+import org.apache.airavata.wsmg.commons.WsmgNameSpaceConstants;
+import org.apache.axiom.om.OMNamespace;
+import org.apache.axiom.soap.SOAPEnvelope;
+import org.apache.axis2.AxisFault;
+import org.apache.axis2.context.MessageContext;
+import org.apache.axis2.engine.AxisEngine;
+import org.apache.axis2.receivers.AbstractMessageReceiver;
+import org.apache.axis2.util.MessageContextBuilder;
+
+public abstract class AbstractBrokerMsgReceiver extends AbstractMessageReceiver {
+
+ protected abstract MessageContext process(MessageContext inMsgContext, String operationName) throws AxisFault;
+
+ @Override
+ protected void invokeBusinessLogic(MessageContext inMsgContext) throws AxisFault {
+
+ String operationName = getOperationName(inMsgContext);
+ MessageContext outMsgContext = process(inMsgContext, operationName);
+
+ if (outMsgContext != null) {
+ outMsgContext.setTo(null);
+ super.replicateState(inMsgContext);
+ AxisEngine.send(outMsgContext);
+
+ }
+
+ }
+
+ protected String getOperationName(MessageContext inMsg) throws AxisFault {
+
+ org.apache.axis2.description.AxisOperation op = inMsg.getOperationContext().getAxisOperation();
+ if (op == null) {
+ throw new AxisFault(
+ "Operation is not located, if this is doclit style the SOAP-ACTION should specified via the SOAP Action to use the RawXMLProvider");
+ }
+
+ java.lang.String operationName = null;
+ if ((op.getName() == null)
+ || ((operationName = org.apache.axis2.util.JavaUtils.xmlNameToJava(op.getName().getLocalPart())) == null)) {
+ throw new AxisFault("invalid operation found");
+ }
+
+ return operationName;
+ }
+
+ protected MessageContext createOutputMessageContext(MessageContext inMsg, ProcessingContext processingContext)
+ throws AxisFault {
+
+ MessageContext outMsgContext = MessageContextBuilder.createOutMessageContext(inMsg);
+ outMsgContext.getOperationContext().addMessageContext(outMsgContext);
+
+ SOAPEnvelope outputEnvelope = getSOAPFactory(inMsg).getDefaultEnvelope();
+
+ if (processingContext.getRespMessage() != null) {
+
+ outputEnvelope.getBody().addChild(processingContext.getRespMessage());
+
+ if (processingContext.getResponseMsgNamespaces() != null) {
+ declareResponseMsgNamespace(outputEnvelope, processingContext.getResponseMsgNamespaces());
+ }
+ }
+
+ outMsgContext.setEnvelope(outputEnvelope);
+ return outMsgContext;
+ }
+
+ private void declareResponseMsgNamespace(SOAPEnvelope outputEnvelope, List<OMNamespace> namespaces) {
+
+ if (!namespaces.contains(WsmgNameSpaceConstants.WSA_NS)) {
+ namespaces.add(WsmgNameSpaceConstants.WSA_NS);// declare WSA by default
+ }
+
+ for (OMNamespace ns : namespaces) {
+ outputEnvelope.declareNamespace(ns);
+ }
+
+ }
+
+}
Added: incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/AdditionalMessageContent.java
URL: http://svn.apache.org/viewvc/incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/AdditionalMessageContent.java?rev=1142453&view=auto
==============================================================================
--- incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/AdditionalMessageContent.java (added)
+++ incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/AdditionalMessageContent.java Sun Jul 3 15:51:36 2011
@@ -0,0 +1,131 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+
+package org.apache.airavata.wsmg.broker;
+
+import java.io.Serializable;
+
+public class AdditionalMessageContent implements Serializable {
+ /**
+ *
+ */
+ private static final long serialVersionUID = -5163025283681463108L;
+
+ String action;
+
+ String messageID;
+
+ String topicElement;
+
+ String producerReference;
+ String trackId;
+
+ /**
+ * @param action
+ * @param messageID
+ */
+ public AdditionalMessageContent(String action, String messageID) {
+ super();
+ // TODO Auto-generated constructor stub
+ this.action = action;
+ this.messageID = messageID;
+ }
+
+ /**
+ * @return Returns the action.
+ */
+ public String getAction() {
+ return action;
+ }
+
+ /**
+ * @param action
+ * The action to set.
+ */
+ public void setAction(String action) {
+ this.action = action;
+ }
+
+ /**
+ * @return Returns the messageID.
+ */
+ public String getMessageID() {
+ return messageID;
+ }
+
+ /**
+ * @param messageID
+ * The messageID to set.
+ */
+ public void setMessageID(String messageID) {
+ this.messageID = messageID;
+ }
+
+ /**
+ * @return Returns the producerReference.
+ */
+ public String getProducerReference() {
+ return producerReference;
+ }
+
+ /**
+ * @param producerReference
+ * The producerReference to set.
+ */
+ public void setProducerReference(String producerReference) {
+ this.producerReference = producerReference;
+ }
+
+ /**
+ * @return Returns the topicElement.
+ */
+ public String getTopicElement() {
+ return topicElement;
+ }
+
+ /**
+ * @param topicElement
+ * The topicElement to set.
+ */
+ public void setTopicElement(String topicElement) {
+ this.topicElement = topicElement;
+ }
+
+ /**
+ * @return Returns the trackId.
+ */
+ public String getTrackId() {
+ return trackId;
+ }
+
+ /**
+ * @param trackId
+ * The trackId to set.
+ */
+ public void setTrackId(String trackId) {
+ this.trackId = trackId;
+ }
+
+ public String toString() {
+ return String.format("msgId = %s, trackId = %s, topic = %s", messageID, trackId, topicElement);
+ }
+
+}
Added: incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/BrokerServiceLifeCycle.java
URL: http://svn.apache.org/viewvc/incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/BrokerServiceLifeCycle.java?rev=1142453&view=auto
==============================================================================
--- incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/BrokerServiceLifeCycle.java (added)
+++ incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/BrokerServiceLifeCycle.java Sun Jul 3 15:51:36 2011
@@ -0,0 +1,221 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+
+package org.apache.airavata.wsmg.broker;
+
+import java.util.Iterator;
+import java.util.List;
+
+import org.apache.airavata.wsmg.broker.handler.PublishedMessageHandler;
+import org.apache.airavata.wsmg.broker.subscription.SubscriptionManager;
+import org.apache.airavata.wsmg.commons.WsmgCommonConstants;
+import org.apache.airavata.wsmg.commons.storage.WsmgInMemoryStorage;
+import org.apache.airavata.wsmg.commons.storage.WsmgPersistantStorage;
+import org.apache.airavata.wsmg.commons.storage.WsmgStorage;
+import org.apache.airavata.wsmg.config.ConfigurationManager;
+import org.apache.airavata.wsmg.config.WSMGParameter;
+import org.apache.airavata.wsmg.config.WsmgConfigurationContext;
+import org.apache.airavata.wsmg.messenger.ConsumerUrlManager;
+import org.apache.airavata.wsmg.messenger.strategy.SendingStrategy;
+import org.apache.airavata.wsmg.messenger.strategy.impl.FixedParallelSender;
+import org.apache.airavata.wsmg.messenger.strategy.impl.ParallelSender;
+import org.apache.airavata.wsmg.messenger.strategy.impl.SerialSender;
+import org.apache.airavata.wsmg.util.RunTimeStatistics;
+import org.apache.axis2.AxisFault;
+import org.apache.axis2.context.ConfigurationContext;
+import org.apache.axis2.description.AxisService;
+import org.apache.axis2.engine.Handler;
+import org.apache.axis2.engine.Phase;
+import org.apache.log4j.Logger;
+
+public class BrokerServiceLifeCycle implements org.apache.axis2.engine.ServiceLifeCycle {
+
+ Logger log = Logger.getLogger(BrokerServiceLifeCycle.class);
+ SendingStrategy method = null;
+
+ public void shutDown(ConfigurationContext arg, AxisService service) {
+
+ log.info("broker shutting down");
+
+ if (method != null) {
+ method.shutdown();
+ }
+
+ }
+
+ public void startUp(ConfigurationContext configContext, AxisService axisService) {
+
+ Boolean inited = (Boolean) configContext.getProperty(WsmgCommonConstants.BROKER_INITED);
+
+ if (inited == null || inited == false) {
+
+ log.info("starting broker");
+
+ overrideAddressingPhaseHander(configContext);
+ initConfigurations(configContext, axisService);
+
+ WsmgConfigurationContext brokerConext = (WsmgConfigurationContext) configContext
+ .getProperty(WsmgCommonConstants.BROKER_WSMGCONFIG);
+
+ initQueue(brokerConext.getStorage());
+ initDeliveryMethod(brokerConext.getConfigurationManager());
+
+ inited = true;
+ configContext.setProperty(WsmgCommonConstants.BROKER_INITED, inited);
+ } else {
+ log.info("init was already done by another webservice");
+ }
+ }
+
+ private void initConfigurations(ConfigurationContext configContext, AxisService axisService) {
+
+ WsmgConfigurationContext wsmgConfig = new WsmgConfigurationContext();
+ configContext.setProperty(WsmgCommonConstants.BROKER_WSMGCONFIG, wsmgConfig);
+
+ ConfigurationManager configMan = new ConfigurationManager(WsmgCommonConstants.BROKER_CONFIGURATION_FILE_NAME);
+
+ wsmgConfig.setConfigurationManager(configMan);
+
+ String type = configMan.getConfig(WsmgCommonConstants.CONFIG_STORAGE_TYPE,
+ WsmgCommonConstants.STORAGE_TYPE_PERSISTANT);
+
+ WsmgStorage storage = null;
+
+ if (WsmgCommonConstants.STORAGE_TYPE_IN_MEMORY.equalsIgnoreCase(type)) {
+ storage = new WsmgInMemoryStorage();
+ } else {
+ try {
+ storage = new WsmgPersistantStorage(WsmgCommonConstants.TABLE_NAME_EXPIRABLE_SUBCRIPTIONS,
+ WsmgCommonConstants.TABLE_NAME_NON_EXPIRABLE_SUBCRIPTIONS, configMan);
+
+ } catch (AxisFault e) {
+ throw new RuntimeException("unable to init persistant storage", e);
+ }
+ }
+
+ wsmgConfig.setStorage(storage);
+
+ SubscriptionManager subManager = new SubscriptionManager(wsmgConfig, storage);
+ wsmgConfig.setSubscriptionManager(subManager);
+
+ NotificationProcessor notificatonProcessor = new NotificationProcessor(wsmgConfig);
+ wsmgConfig.setNotificationProcessor(notificatonProcessor);
+
+ }
+
+ private void initQueue(WsmgStorage storage) {
+
+ log.info("setting up queue");
+
+ WSMGParameter.OUT_GOING_QUEUE = storage;
+
+ if (WSMGParameter.cleanQueueonStartUp) {
+ log.debug("cleaning up persistant queue");
+ WSMGParameter.OUT_GOING_QUEUE.cleanup();
+ log.debug("cleaned up persistant queue");
+ }
+
+ RunTimeStatistics.setStartUpTime();
+
+ }
+
+ private void initDeliveryMethod(ConfigurationManager configMan) {
+
+ String shouldStart = configMan.getConfig(WsmgCommonConstants.CONFIG_START_DELIVERY_THREADS);
+
+ if (!Boolean.parseBoolean(shouldStart)) {
+
+ if (configMan.getConfig(WsmgCommonConstants.CONFIG_STORAGE_TYPE,
+ WsmgCommonConstants.STORAGE_TYPE_PERSISTANT).equalsIgnoreCase(
+ WsmgCommonConstants.STORAGE_TYPE_IN_MEMORY)) {
+
+ // user has asked to use in memory queue
+ // but with out starting the delivery thread.
+ // this will accumulate message in memory.
+
+ log.error("conflicting configuration ditected, " + "using in memory queue with out starting delivery "
+ + "thread will result memory growth.");
+
+ }
+
+ return;
+ }
+
+ String deliveryMethod = configMan.getConfig(WsmgCommonConstants.CONFIG_DELIVERY_METHOD,
+ WsmgCommonConstants.DELIVERY_METHOD_SERIAL);
+
+ ConsumerUrlManager urlManager = new ConsumerUrlManager(configMan);
+
+ String initedmethod = null;
+
+ if (WsmgCommonConstants.DELIVERY_METHOD_PARALLEL.equalsIgnoreCase(deliveryMethod)) {
+
+ method = new ParallelSender(configMan, urlManager);
+ initedmethod = WsmgCommonConstants.DELIVERY_METHOD_PARALLEL;
+
+ } else if (WsmgCommonConstants.DELIVERY_METHOD_THREAD_CREW.equalsIgnoreCase(deliveryMethod)) {
+ method = new FixedParallelSender(configMan, urlManager);
+ initedmethod = WsmgCommonConstants.DELIVERY_METHOD_THREAD_CREW;
+ } else {
+ method = new SerialSender(configMan, urlManager);
+ initedmethod = WsmgCommonConstants.DELIVERY_METHOD_SERIAL;
+ }
+
+ method.start();
+ log.info(initedmethod + " sending method inited");
+ }
+
+ /**
+ * @param configContext
+ */
+ private void overrideAddressingPhaseHander(ConfigurationContext configContext) {
+
+ List<Phase> inflowPhases = configContext.getAxisConfiguration().getPhasesInfo().getINPhases();
+ boolean foundFlag = false;
+
+ for (Phase p : inflowPhases) {
+
+ if (p.getName().equalsIgnoreCase("Addressing")) {
+
+ List<Handler> handlers = p.getHandlers();
+
+ for (Iterator<Handler> ite = handlers.iterator(); ite.hasNext();) {
+ Handler h = ite.next();
+ if (h.getClass().isAssignableFrom(PublishedMessageHandler.class)) {
+ p.removeHandler(h.getHandlerDesc());
+ break;
+ }
+ }
+
+ p.addHandler(new PublishedMessageHandler(), 0);
+ foundFlag = true;
+ break;
+ }
+
+ }
+
+ if (!foundFlag) {
+ throw new RuntimeException("unable to find addressing phase - inside inflow phases");
+ }
+
+ }
+
+}
Added: incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/ConsumerInfo.java
URL: http://svn.apache.org/viewvc/incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/ConsumerInfo.java?rev=1142453&view=auto
==============================================================================
--- incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/ConsumerInfo.java (added)
+++ incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/ConsumerInfo.java Sun Jul 3 15:51:36 2011
@@ -0,0 +1,123 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+
+package org.apache.airavata.wsmg.broker;
+
+import java.io.Serializable;
+
+public class ConsumerInfo implements Serializable {
+ static final long serialVersionUID = 2274650724788817903L;
+
+ // TODO : change this to OM, EndpointReference.
+ String consumerEprStr;
+
+ String type; // Either "wsnt" or "wse"
+
+ boolean useNotify;
+
+ boolean paused = false;
+
+ boolean wsrmEnabled;
+
+ /**
+ * @param consumerEprStr
+ * @param type
+ * @param useNotify
+ * @param paused
+ */
+ public ConsumerInfo(String consumerEprStr, String type, boolean useNotify, boolean paused) {
+ super();
+ // TODO Auto-generated constructor stub
+ this.consumerEprStr = consumerEprStr;
+ this.type = type;
+ this.useNotify = useNotify;
+ this.paused = paused;
+ }
+
+ /**
+ * @return Returns the consumerEprStr.
+ */
+ public String getConsumerEprStr() {
+ return consumerEprStr;
+ }
+
+ /**
+ * @param consumerEprStr
+ * The consumerEprStr to set.
+ */
+ public void setConsumerEprStr(String consumerEprStr) {
+ this.consumerEprStr = consumerEprStr;
+ }
+
+ /**
+ * @return Returns the paused.
+ */
+ public boolean isPaused() {
+ return paused;
+ }
+
+ /**
+ * @param paused
+ * The paused to set.
+ */
+ public void setPaused(boolean paused) {
+ this.paused = paused;
+ }
+
+ /**
+ * @return Returns the type.
+ */
+ public String getType() {
+ return type;
+ }
+
+ /**
+ * @param type
+ * The type to set.
+ */
+ public void setType(String type) {
+ this.type = type;
+ }
+
+ /**
+ * @return Returns the useNotify.
+ */
+ public boolean isUseNotify() {
+ return useNotify;
+ }
+
+ /**
+ * @param useNotify
+ * The useNotify to set.
+ */
+ public void setUseNotify(boolean useNotify) {
+ this.useNotify = useNotify;
+ }
+
+ public boolean isWsrmEnabled() {
+ return wsrmEnabled;
+ }
+
+ public void setWsrmEnabled(boolean wsrmEnabled) {
+ this.wsrmEnabled = wsrmEnabled;
+ }
+
+}
Added: incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/ConsumerList.java
URL: http://svn.apache.org/viewvc/incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/ConsumerList.java?rev=1142453&view=auto
==============================================================================
--- incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/ConsumerList.java (added)
+++ incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/ConsumerList.java Sun Jul 3 15:51:36 2011
@@ -0,0 +1,73 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+
+package org.apache.airavata.wsmg.broker;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.Map;
+
+public class ConsumerList {
+ Map<String, ConsumerInfo> subId2ConsumerInfo = new HashMap<String, ConsumerInfo>();
+
+ ArrayList<ConsumerInfo> consumerInfoList = new ArrayList<ConsumerInfo>();
+
+ boolean changed = true;
+ int size = 0; // use size instead of consumerInfoList.size() to avoid
+
+ // unnecessary copy of subId2ConsumerInfo in
+ // refreshConsumerInfoList() if just need the size
+
+ public void addConsumer(String subId, ConsumerInfo consumerInfo) {
+ subId2ConsumerInfo.put(subId, consumerInfo);
+ changed = true;
+ size++;
+ }
+
+ public int removeConsumer(String subId) {
+ ConsumerInfo result = subId2ConsumerInfo.remove(subId);
+ if (result == null) {
+ return 0;
+ }
+ changed = true;
+ size--;
+ return 1;
+
+ }
+
+ public ArrayList<ConsumerInfo> getConsumerList() {
+ if (changed) {
+ refreshConsumerInfoList();
+ }
+ return consumerInfoList;
+ }
+
+ public int size() {
+ return size;
+ }
+
+ private void refreshConsumerInfoList() {
+ consumerInfoList.clear();
+ consumerInfoList.addAll(subId2ConsumerInfo.values());
+ changed = false;
+ }
+
+}
Added: incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/ConsumerListManager.java
URL: http://svn.apache.org/viewvc/incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/ConsumerListManager.java?rev=1142453&view=auto
==============================================================================
--- incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/ConsumerListManager.java (added)
+++ incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/ConsumerListManager.java Sun Jul 3 15:51:36 2011
@@ -0,0 +1,78 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+
+package org.apache.airavata.wsmg.broker;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import org.apache.airavata.wsmg.broker.subscription.SubscriptionState;
+import org.apache.log4j.Logger;
+
+public class ConsumerListManager {
+
+ protected Map<String, ConsumerList> token2ConsumerListMap = new HashMap<String, ConsumerList>();
+
+ protected Map<String, String> subId2Token = new HashMap<String, String>();
+
+ Logger logger = Logger.getLogger(ConsumerListManager.class);
+
+ // token can be a topic or an XPath String
+ public void addToConsumerList(String token, SubscriptionState subscribeRequest, String subscriptionId) {
+ ConsumerList consumerList = token2ConsumerListMap.get(token);
+ if (consumerList == null) { // new topic
+ consumerList = new ConsumerList();
+ token2ConsumerListMap.put(token, consumerList);
+ }
+ consumerList.addConsumer(subscriptionId, subscribeRequest.getConsumerInfo());
+ subId2Token.put(subscriptionId, token);
+
+ }
+
+ public String getTokenBySubscriptionId(String subscriptionId) {
+ String token = subId2Token.get(subscriptionId);
+ return token;
+ }
+
+ public int removeFromConsumerList(String subscriptionId, String token) {
+ String tokenString = null;
+ if (token == null) {
+ tokenString = subId2Token.get(subscriptionId);
+ } else {
+ tokenString = token;
+ }
+
+ ConsumerList consumerList = token2ConsumerListMap.get(tokenString);
+ if (consumerList == null) {
+ logger.fatal("*****ERROR:Cannot find the token to delete: " + tokenString);
+ return 0;
+ }
+ int result = consumerList.removeConsumer(subscriptionId);
+ subId2Token.remove(subscriptionId);
+ return result;
+ }
+
+ public ConsumerList getConsumerListByToken(String token) {
+ ConsumerList consumerList = token2ConsumerListMap.get(token);
+ return consumerList;
+ }
+
+}
Added: incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/NotificationProcessor.java
URL: http://svn.apache.org/viewvc/incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/NotificationProcessor.java?rev=1142453&view=auto
==============================================================================
--- incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/NotificationProcessor.java (added)
+++ incubator/airavata/ws-messaging/trunk/messagebroker/src/main/java/org/apache/airavata/wsmg/broker/NotificationProcessor.java Sun Jul 3 15:51:36 2011
@@ -0,0 +1,322 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+
+package org.apache.airavata.wsmg.broker;
+
+import java.util.Iterator;
+import java.util.LinkedList;
+import java.util.List;
+
+import javax.xml.namespace.QName;
+import javax.xml.stream.XMLStreamException;
+
+import org.apache.airavata.wsmg.broker.context.ContextParameters;
+import org.apache.airavata.wsmg.broker.context.ProcessingContext;
+import org.apache.airavata.wsmg.commons.OutGoingMessage;
+import org.apache.airavata.wsmg.commons.WsmgNameSpaceConstants;
+import org.apache.airavata.wsmg.config.WSMGParameter;
+import org.apache.airavata.wsmg.config.WsmgConfigurationContext;
+import org.apache.airavata.wsmg.matching.AbstractMessageMatcher;
+import org.apache.airavata.wsmg.messenger.OutGoingQueue;
+import org.apache.airavata.wsmg.util.RunTimeStatistics;
+import org.apache.airavata.wsmg.util.WsmgUtil;
+import org.apache.axiom.om.OMAbstractFactory;
+import org.apache.axiom.om.OMAttribute;
+import org.apache.axiom.om.OMElement;
+import org.apache.axiom.om.OMException;
+import org.apache.axiom.om.OMFactory;
+import org.apache.axiom.om.OMNamespace;
+import org.apache.axis2.AxisFault;
+import org.apache.log4j.Logger;
+
+public class NotificationProcessor {
+
+ org.apache.log4j.Logger logger = Logger.getLogger(NotificationProcessor.class);
+
+ WsmgConfigurationContext wsmgConfigContext = null;
+
+ protected long messageCounter = 0;
+ protected long messageId = 0;
+
+ OMFactory factory = OMAbstractFactory.getOMFactory();
+
+ OutGoingQueue outgoingQueue = null;
+
+ public NotificationProcessor(WsmgConfigurationContext config) {
+ init(config);
+ }
+
+ private void init(WsmgConfigurationContext config) {
+ this.wsmgConfigContext = config;
+ outgoingQueue = config.getOutgoingQueue();
+
+ // Ramith : JMS support is removed.
+ assert (!WSMGParameter.useIncomingQueue);
+ /*
+ * PublisherThread publisherThread = new PublisherThread(wsmgConfigContext); new
+ * Thread(publisherThread).start();
+ */
+
+ }
+
+ private synchronized long getNextTrackId() {
+ messageCounter++;
+ return messageCounter;
+ }
+
+ private synchronized long getNextMsgId() {
+ messageId++;
+ return messageId;
+ }
+
+ public void processMsg(ProcessingContext ctx, OMNamespace protocolNs) throws OMException, AxisFault {
+
+ String trackId = "trackId_A_" + getNextTrackId();
+ if (WSMGParameter.showTrackId) {
+ logger.debug(trackId + ": received.");
+ }
+
+ AdditionalMessageContent additionalMessageContent = new AdditionalMessageContent(ctx.getMessageContext()
+ .getSoapAction(), ctx.getMessageContext().getMessageID());
+ additionalMessageContent.setTrackId(trackId);
+
+ if (WsmgNameSpaceConstants.WSNT_NS.equals(protocolNs)) {
+
+ onWSNTMsg(ctx, additionalMessageContent);
+ setResponseMsg(ctx, trackId, protocolNs);
+ } else { // WSE Notifications No specific namespace
+
+ onWSEMsg(ctx, trackId, additionalMessageContent);
+ setResponseMsg(ctx, trackId, protocolNs);
+ }
+
+ }
+
+ /**
+ * @param ctx
+ * @param topicElString
+ * @param trackId
+ * @param additionalMessageContent
+ * @throws OMException
+ * @throws XMLStreamException
+ */
+ private void onWSEMsg(ProcessingContext ctx, String trackId, AdditionalMessageContent additionalMessageContent)
+ throws OMException, AxisFault {
+
+ String topicElString = null;
+ String topicLocalString = null;
+
+ QName qName = new QName(WsmgNameSpaceConstants.WSNT_NS.getNamespaceURI(), "Topic");
+
+ OMElement topicEl = ctx.getMessageContext().getEnvelope().getHeader().getFirstChildWithName(qName);
+
+ if (topicEl == null) {
+
+ topicLocalString = ctx.getContextParameter(ContextParameters.TOPIC_FROM_URL);
+
+ if (topicLocalString != null) {
+
+ topicElString = "<wsnt:Topic "
+ + "Dialect=\"http://www.ibm.com/xmlns/stdwip/web-services/WS-Topics/TopicExpression/simple\" "
+ + "xmlns:ns2=\"http://tutorial.globus.org/auction\" "
+ + "xmlns:wsnt=\"http://www.ibm.com/xmlns/stdwip/web-services/WS-BaseNotification\">" + "ns2:"
+ + topicLocalString + "</wsnt:Topic>";
+ // / }
+ additionalMessageContent.setTopicElement(topicElString);
+ } else {
+
+ topicLocalString = "wseTopic";
+ topicElString = "<wsnt:Topic "
+ + "Dialect=\"http://www.ibm.com/xmlns/stdwip/web-services/WS-Topics/TopicExpression/simple\" "
+ + "xmlns:ns2=\"http://tutorial.globus.org/auction\" "
+ + "xmlns:wsnt=\"http://www.ibm.com/xmlns/stdwip/web-services/WS-BaseNotification\">"
+ + "ns2:wseTopic</wsnt:Topic>";
+ // / }
+ additionalMessageContent.setTopicElement(topicElString);
+ }
+ } else {
+
+ topicLocalString = WsmgUtil.getTopicLocalString(topicEl.getText());
+ try {
+ topicElString = topicEl.toStringWithConsume();
+ } catch (XMLStreamException e) {
+ // TODO Auto-generated catch block Add throw
+ logger.fatal("exceptions occured at WSE " + "eventing notification creating", e);
+ }
+ additionalMessageContent.setTopicElement(topicElString);
+ }
+
+ OMElement messageEl = ctx.getSoapBody().getFirstElement();
+ if (messageEl == null) {
+ throw new AxisFault("no message found");
+ }
+
+ String message = null;
+ try {
+ message = messageEl.toStringWithConsume();
+ } catch (XMLStreamException e) {
+ logger.error("unable to serialize the message", e);
+ throw new AxisFault("unable to serialize the message", e);
+ }
+
+ matchAndSave(message, topicLocalString, additionalMessageContent);
+ }
+
+ /**
+ * @param ctx
+ * @param trackId
+ * @throws OMException
+ */
+ private void setResponseMsg(ProcessingContext ctx, String trackId, OMNamespace responseNS) throws OMException {
+ // set response message
+
+ ctx.addResponseMsgNameSpaces(responseNS);
+
+ OMAttribute trackIdAttribute = factory.createOMAttribute("trackId", null, trackId);
+ OMElement messageElement = ctx.getMessageContext().getEnvelope().getBody().getFirstElement();
+ OMElement responseMsgElement = factory.createOMElement(messageElement.getLocalName() + "Response", responseNS);
+ responseMsgElement.addAttribute(trackIdAttribute);
+ ctx.setRespMessage(responseMsgElement);
+
+ }
+
+ /**
+ * @param ctx
+ * @param topicLocalString
+ * @param topicElString
+ * @param producerReferenceElString
+ * @param additionalMessageContent
+ * @throws OMException
+ * @throws XMLStreamException
+ * @throws AxisFault
+ */
+ private void onWSNTMsg(ProcessingContext ctx, AdditionalMessageContent additionalMessageContent)
+ throws OMException, AxisFault {
+
+ String producerReferenceElString = null;
+ String topicElString = null;
+
+ boolean noElements = true;
+
+ // TODO: set nicely with a processing context
+ OMElement notifyEl = ctx.getSoapBody().getFirstElement();
+ for (Iterator<OMElement> iter = notifyEl.getChildrenWithLocalName("NotificationMessage"); iter.hasNext();) {
+ noElements = false;
+ OMElement wrappedMessageEl = iter.next();
+
+ String topicLocalString = null;
+
+ OMElement topicEl = wrappedMessageEl.getFirstChildWithName(new QName(WsmgNameSpaceConstants.WSNT_NS
+ .getNamespaceURI(), "Topic"));
+ if (topicEl != null) {
+
+ topicLocalString = WsmgUtil.getTopicLocalString(topicEl.getText()); // get what ever inside this element
+
+ try {
+ topicElString = topicEl.toStringWithConsume();
+ } catch (XMLStreamException e) {
+ // TODO Add with throws block
+ logger.fatal("exception occured while " + "creating NotificationConsumer", e);
+
+ }
+ additionalMessageContent.setTopicElement(topicElString);
+ }
+ OMElement producerReferenceEl = wrappedMessageEl.getFirstChildWithName(new QName(
+ WsmgNameSpaceConstants.WSNT_NS.getNamespaceURI(), "ProducerReference"));
+
+ if (producerReferenceEl != null) {
+ try {
+ producerReferenceElString = producerReferenceEl.toStringWithConsume();
+ } catch (XMLStreamException e) {
+
+ logger.fatal("exception occured while " + "creating notification consumer", e);
+
+ }
+ additionalMessageContent.setProducerReference(producerReferenceElString);
+ }
+
+ OMElement notificationMessageEl = wrappedMessageEl.getFirstChildWithName(
+ new QName(WsmgNameSpaceConstants.WSNT_NS.getNamespaceURI(), "Message")).getFirstElement();
+
+ String message = null;
+ try {
+ message = notificationMessageEl.toStringWithConsume();
+ } catch (XMLStreamException e) {
+ logger.error("exception occured while " + "creating notification consumer", e);
+
+ throw new AxisFault("unable to serialize the message", e);
+ }
+
+ matchAndSave(message, topicLocalString, additionalMessageContent);
+
+ }
+ if (noElements) {
+ throw new AxisFault("at least one element is required");
+ }
+ }
+
+ private void matchAndSave(String notificationMessage, String topicLocalString,
+ AdditionalMessageContent additionalMessageContent) {
+
+ // Ramith: Jms support is not implemented now.
+ assert (!WSMGParameter.useIncomingQueue);
+
+ List<ConsumerInfo> matchedConsumers = new LinkedList<ConsumerInfo>();
+
+ // not use incoming queue
+ // This is a fix for the bug seen in yfilter.
+ try {
+
+ for (AbstractMessageMatcher matcher : wsmgConfigContext.getMessageMatchers()) {
+ matcher.populateMatches(null, additionalMessageContent, notificationMessage, topicLocalString,
+ matchedConsumers);
+ }
+
+ save(matchedConsumers, notificationMessage, additionalMessageContent);
+
+ } catch (RuntimeException e) {
+ logger.fatal("Caught RuntimeException", e);
+ }
+
+ }
+
+ public void save(List<ConsumerInfo> consumerInfoList, String message,
+ AdditionalMessageContent additionalMessageContent) {
+
+ if (consumerInfoList.size() == 0) // No subscription
+ return;
+
+ assert (WSMGParameter.useOutGoingQueue); // we will only use out going
+ // queue for the moment
+
+ RunTimeStatistics.addNewNotificationMessageSize(message.length());
+ OutGoingMessage outGoingMessage = new OutGoingMessage();
+ outGoingMessage.setTextMessage(message);
+ outGoingMessage.setConsumerInfoList(consumerInfoList);
+ outGoingMessage.setAdditionalMessageContent(additionalMessageContent);
+
+ outgoingQueue.storeNotification(outGoingMessage, getNextMsgId());
+
+ if (WSMGParameter.showTrackId)
+ logger.info(additionalMessageContent.getTrackId() + ": putIn Outgoing queue.");
+ }
+
+}