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 02:29:37 UTC
svn commit: r1142350 [1/18] - in
/incubator/airavata/donations/ogce-donation/modules/ws-messaging: broker/
broker/customLibs/ broker/customLibs/activeMQ/ broker/src/ broker/src/main/
broker/src/main/java/ broker/src/main/java/wsmg/ broker/src/main/java...
Author: smarru
Date: Sun Jul 3 00:29:24 2011
New Revision: 1142350
URL: http://svn.apache.org/viewvc?rev=1142350&view=rev
Log:
ensuring all donations are in place
Added:
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/customLibs/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/customLibs/activeMQ/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/customLibs/activeMQ/amq.jar (with props)
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/customLibs/activeMQ/geronimo-spec-jms-1.1-rc4.jar (with props)
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/customLibs/util-concurrent.jar (with props)
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/customLibs/zFilter.jar (with props)
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/pom.xml
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/NotificationHandler.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/AbstractBrokerMsgReceiver.java (with props)
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/AdditionalMessageContent.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/BrokerServiceLifeCycle.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/ConsumerInfo.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/ConsumerList.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/ConsumerListManager.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/NotificationProcessor.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/context/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/context/ContextFactory.java (with props)
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/context/ContextParameterInfo.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/context/ContextParameters.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/context/ProcessingContext.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/context/ProcessingContextBuilder.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/context/ProcessingContextFactory.java (with props)
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/handler/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/handler/PublishedMessageHandler.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/msg/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/msg/recievers/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/subscription/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/subscription/CleanupThread.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/subscription/PublisherRegistrationManager.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/subscription/SubscriptionEntry.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/subscription/SubscriptionManager.java (with props)
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/subscription/SubscriptionState.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/wseventing/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/wseventing/WSEProcessingContextBuilder.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/wseventing/WSEProtocolSupport.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/wseventing/WSEventingMsgReceiver.java (with props)
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/wseventing/WSEventingPublishMsgReceiver.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/wsnotification/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/wsnotification/WSNTProtocolSupport.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/wsnotification/WSNotificationMsgReceiver.java (with props)
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/wsnotification/WSNotificationProcessingContextBuilder.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/client/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/client/CommonClientProcessing.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/client/ConsumerMsgReceiver.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/client/ConsumerNotificationHandler.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/client/ConsumerServer.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/client/ConsumerServerHandler.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/client/ConsumerService.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/client/MessageBrokerClient.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/client/MsgBrokerClientException.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/client/NotificationHandler.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/client/NotificationProducerStub.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/client/SubscriptionInfo.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/client/SubscriptionStub.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/client/WidgetStub.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/client/WseClientAPI.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/client/WseCreateSubscription.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/client/WseMsgBrokerClient.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/client/WsmgClientAPI.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/client/WsntClientAPI.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/client/WsntCreatePublishReg.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/client/WsntMsgBrokerClient.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/client/WsrfResourceStub.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/client/msgbox/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/client/msgbox/MessagePuller.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/client/msgbox/MsgboxHandler.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/commons/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/commons/CommonRoutines.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/commons/NotificationProducer.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/commons/OutGoingMessage.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/commons/WsmgCommonConstants.java (with props)
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/commons/WsmgNameSpaceConstants.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/commons/WsmgVersion.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/commons/XMLConstants.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/commons/exceptions/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/commons/exceptions/XMLComparisonException.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/commons/storage/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/commons/storage/ConnectionPool.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/commons/storage/JdbcStorage.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/commons/storage/KeyValueWrapper.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/commons/storage/WsmgInMemoryStorage.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/commons/storage/WsmgPersistantStorage.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/commons/storage/WsmgStorage.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/commons/util/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/commons/util/OMElementComparator.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/config/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/config/Configuration.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/config/ConfigurationManager.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/config/ConfigurationParamsReader.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/config/WSMGParameter.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/config/WsmgConfigurationContext.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/gui/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/gui/NotificationViewer.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/gui/NotificationViewerFrame.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/gui/README.txt
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/gui/WsntViewerConsumerNotificationHandler.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/matching/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/matching/AbstractMessageMatcher.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/matching/XPath/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/matching/XPath/BitSetUtil.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/matching/XPath/YFilterInfo.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/matching/XPath/YFilterMessageMatcher.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/matching/XPath/util/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/matching/XPath/util/BitSetUtil.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/matching/simpleTopic/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/matching/simpleTopic/DirectWsntMessageMatcher.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/messenger/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/messenger/ConsumerUrlManager.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/messenger/OutGoingQueue.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/messenger/SenderUtils.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/messenger/protocol/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/messenger/protocol/Axis2Protocol.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/messenger/protocol/DeliveryProtocol.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/messenger/protocol/SendingException.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/messenger/strategy/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/messenger/strategy/SendingStrategy.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/messenger/strategy/impl/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/messenger/strategy/impl/FixedParallelSender.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/messenger/strategy/impl/LightweightMsg.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/messenger/strategy/impl/ParallelSender.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/messenger/strategy/impl/SerialSender.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/messenger/strategy/impl/ThreadCrew.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/processors/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/processors/OutGoingMessage.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/processors/PublisherRegistrationManager.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/processors/ReceivedMessage.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/transports/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/transports/jms/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/transports/jms/MessageMatcherConnection.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/util/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/util/Counter.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/util/CurrentDate.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/util/DcDate.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/util/LoadConfigProperties.java (with props)
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/util/RunTimeStatistics.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/util/TimerThread.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/util/WsEventingOperations.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/util/WsNotificationOperations.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/util/WsmgUtil.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/util/test/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/util/test/TestUtilServer.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/resources/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/resources/addressing-1.5.mar (with props)
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/resources/database_scripts/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/resources/database_scripts/cleanDBScript.sql (with props)
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/resources/database_scripts/mysqlCreationScript.sql (with props)
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/resources/log4j.properties.txt
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/resources/services.xml
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers-topics/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers-topics/README.txt
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers-topics/build.properties
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers-topics/build.xml
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers-topics/conf/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers-topics/conf/configurations.properties
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers-topics/src/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers-topics/src/wsmg/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers-topics/src/wsmg/samples/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers-topics/src/wsmg/samples/util/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers-topics/src/wsmg/samples/util/ConfigKeys.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers-topics/src/wsmg/samples/wse/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers-topics/src/wsmg/samples/wse/Consumer.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers-topics/src/wsmg/samples/wse/MsgUtil.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers-topics/src/wsmg/samples/wse/MultipleProducersConsumersTopics.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers-topics/src/wsmg/samples/wse/Producer.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers-xpath/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers-xpath/README.txt
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers-xpath/build.properties
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers-xpath/build.xml
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers-xpath/conf/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers-xpath/conf/configurations.properties
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers-xpath/src/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers-xpath/src/wsmg/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers-xpath/src/wsmg/samples/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers-xpath/src/wsmg/samples/util/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers-xpath/src/wsmg/samples/util/ConfigKeys.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers-xpath/src/wsmg/samples/wse/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers-xpath/src/wsmg/samples/wse/Consumer.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers-xpath/src/wsmg/samples/wse/MultipleProducersConsumers.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers-xpath/src/wsmg/samples/wse/Producer.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers/README.txt
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers/build.properties
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers/build.xml
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers/conf/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers/conf/configurations.properties
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers/src/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers/src/wsmg/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers/src/wsmg/samples/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers/src/wsmg/samples/util/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers/src/wsmg/samples/util/ConfigKeys.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers/src/wsmg/samples/wse/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers/src/wsmg/samples/wse/Consumer.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers/src/wsmg/samples/wse/MultipleProducersConsumers.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-multiple-producers-consumers/src/wsmg/samples/wse/Producer.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-round-trip/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-round-trip/README.txt
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-round-trip/build.properties
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-round-trip/build.xml
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-round-trip/conf/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-round-trip/conf/configurations.properties
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-round-trip/src/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-round-trip/src/wsmg/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-round-trip/src/wsmg/samples/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-round-trip/src/wsmg/samples/util/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-round-trip/src/wsmg/samples/util/ConfigKeys.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-round-trip/src/wsmg/samples/wse/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-round-trip/src/wsmg/samples/wse/Consumer.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-round-trip/src/wsmg/samples/wse/Producer.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-round-trip/src/wsmg/samples/wse/WSERoundTrip.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-topic-subscription/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-topic-subscription/README.txt
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-topic-subscription/build.properties
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-topic-subscription/build.xml
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-topic-subscription/conf/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-topic-subscription/conf/configurations.properties
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-topic-subscription/src/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-topic-subscription/src/wsmg/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-topic-subscription/src/wsmg/samples/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-topic-subscription/src/wsmg/samples/util/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-topic-subscription/src/wsmg/samples/util/ConfigKeys.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-topic-subscription/src/wsmg/samples/wse/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-topic-subscription/src/wsmg/samples/wse/TopicSubscribe.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-xpath-subscription/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-xpath-subscription/README.txt
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-xpath-subscription/build.properties
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-xpath-subscription/build.xml
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-xpath-subscription/conf/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-xpath-subscription/conf/configurations.properties
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-xpath-subscription/src/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-xpath-subscription/src/wsmg/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-xpath-subscription/src/wsmg/samples/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-xpath-subscription/src/wsmg/samples/util/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-xpath-subscription/src/wsmg/samples/util/ConfigKeys.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-xpath-subscription/src/wsmg/samples/wse/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wse-xpath-subscription/src/wsmg/samples/wse/XpathSubscribe.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wsmg-gui/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wsmg-gui/README.txt
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wsmg-gui/build.properties
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/samples/wsmg-gui/build.xml
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/performance_evaluator/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/performance_evaluator/rtt/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/performance_evaluator/rtt/NotificationManager.java (with props)
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/performance_evaluator/rtt/PerformanceTest.java (with props)
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/performance_evaluator/rtt/PublisherThread.java (with props)
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/performance_evaluator/rtt/StatCalculatorThread.java (with props)
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/performance_evaluator/rtt/StatContainer.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/performance_evaluator/rtt/Subscription.java (with props)
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/performance_evaluator/rtt/util/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/performance_evaluator/rtt/util/ConfigKeys.java (with props)
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/performance_evaluator/rtt/util/LoadMsgPayload.java (with props)
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/performance_evaluator/rtt/util/LoadXpath.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/broker/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/broker/BrokerWSETest.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/broker/BrokerWSNTTest.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/client/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/client/TestWseMsgBrokerClient.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/client/TestWsntMsgBrokerClient.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/client/WseClientAPIConsumerTest.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/client/WseClientAPIPublishTest.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/client/WseClientAPIRoundTripTests.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/client/WseClientAPISubscriptionsTest.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/client/WseClientAPITest.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/client/WsntClientAPIConsumerTest.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/client/WsntClientAPIPublishTest.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/client/WsntClientAPIRoundTripTests.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/client/WsntClientAPISubscriptionTests.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/commons/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/commons/TestCommonRoutines.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/gui/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/gui/GUITest.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/matching/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/matching/XPath/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/matching/XPath/TestAddtionalWseXpathAndTopicScenarios.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/matching/XPath/TestWseXpathAndTopicSubscription.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/matching/XPath/TestWseXpathSubscription.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/matching/XPath/performance/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/matching/XPath/performance/XppXPath.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/util/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/util/ConfigKeys.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/util/TestDcDate.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/util/TestWsmgUtil.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/widgetTest/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/java/wsmg/widgetTest/Client.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/resources/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/resources/unit_tests.properties
incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/test/resources/wsmg.broker.properties
incubator/airavata/donations/ogce-donation/modules/ws-messaging/messenger/axis2_dependencies/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/messenger/pom.xml
incubator/airavata/donations/ogce-donation/modules/ws-messaging/messenger/src/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/messenger/src/main/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/messenger/src/main/java/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/messenger/src/main/java/wsmg/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/messenger/src/main/java/wsmg/messenger/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/messenger/src/main/java/wsmg/messenger/MessengerServlet.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/messenger/src/main/java/wsmg/messenger/util/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/messenger/src/main/java/wsmg/messenger/util/MessengerLogFactory.java (with props)
incubator/airavata/donations/ogce-donation/modules/ws-messaging/messenger/src/main/resources/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/messenger/src/main/resources/log4jconfig.xml_ (with props)
incubator/airavata/donations/ogce-donation/modules/ws-messaging/messenger/src/main/resources/wsmg.broker.properties.sample
incubator/airavata/donations/ogce-donation/modules/ws-messaging/messenger/src/main/webapp/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/messenger/src/main/webapp/WEB-INF/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/messenger/src/main/webapp/WEB-INF/web.xml
incubator/airavata/donations/ogce-donation/modules/ws-messaging/messenger/src/test/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/messenger/src/test/java/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/pom.xml
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/commons/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/commons/LeadContextHeader.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/commons/LeadCrosscutParametersUtil.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/commons/WorkFlowUtils.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/commons/XBeansUtil.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/AbstractNotifier.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/AuditNotifier.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/GenericNotifier.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/Notifier.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/NotifierFactory.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/PerformanceNotifier.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/ProvenanceNotifier.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/PublisherFactory.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/ResourceNotifier.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/ServiceNotifier.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/WorkflowNotifier.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/WorkflowTrackingException.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/calder/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/calder/CalderNotifier.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/client/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/client/Callback.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/client/LeadNotificationManager.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/client/NotificationType.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/client/Subscription.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/common/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/common/AnnotationConsts.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/common/AnnotationProps.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/common/ConstructorConsts.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/common/ConstructorProps.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/common/DataDurationObj.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/common/DataObj.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/common/DurationObj.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/common/InvocationContext.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/common/InvocationEntity.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/common/NotifierConfig.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/common/NotifierCreationException.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/common/NotifierException.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/common/NotifierVersion.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/common/WorkflowTrackingContext.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/impl/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/impl/GenericNotifierImpl.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/impl/NotifierImpl.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/impl/ProvenanceNotifierImpl.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/impl/publish/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/impl/publish/AbstractPublisher.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/impl/publish/BrokerEntry.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/impl/publish/LoopbackPublisher.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/impl/publish/NotificationPublisher.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/impl/publish/WSMPublisher.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/impl/state/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/impl/state/DataDurationImpl.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/impl/state/DataObjImpl.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/impl/state/DurationImpl.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/impl/state/InvocationContextImpl.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/impl/state/InvocationEntityImpl.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/impl/subscription/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/impl/subscription/LeadNotificationHandler.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/impl/subscription/MessageBoxNotificationHandler.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/samples/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/samples/listener/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/samples/listener/CallbackHandler.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/samples/listener/Listener.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/samples/simple_listener/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/samples/simple_listener/CallbackHandler.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/samples/simple_listener/SimpleListener.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/samples/workflow/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/tests/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/tests/messagebox/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/tests/messagebox/restart/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/util/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/util/ActivityTime.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/util/ConfigKeys.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/util/LinkedMessageQueue.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/util/MessageUtil.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/util/Timer.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/java/edu/indiana/extreme/lead/workflow_tracking/util/XmlBeanUtils.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/resources/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/resources/log4j.properties
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/resources/workflow_tracking.properties
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/xsd/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/xsd/calder_notification_types.xsd
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/xsd/notification_types.xsd
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/xsdconfig/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/xsdconfig/calder_notification_types.xsdconfig (with props)
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/main/xsdconfig/notification_types_ng.xsdconfig (with props)
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/edu/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/edu/indiana/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/edu/indiana/extreme/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/edu/indiana/extreme/lead/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/edu/indiana/extreme/lead/workflow_tracking/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/edu/indiana/extreme/lead/workflow_tracking/LeadCallbackHandlerTest.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/edu/indiana/extreme/lead/workflow_tracking/LeadNotificationManagerTest.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/edu/indiana/extreme/lead/workflow_tracking/MultipleSubscriptionTest.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/edu/indiana/extreme/lead/workflow_tracking/RenewSubscriptionTest.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/edu/indiana/extreme/lead/workflow_tracking/ThreadMessagePassingCallback.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/edu/indiana/extreme/lead/workflow_tracking/impl/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/edu/indiana/extreme/lead/workflow_tracking/impl/publish/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/edu/indiana/extreme/lead/workflow_tracking/impl/publish/Test.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/edu/indiana/extreme/lead/workflow_tracking/impl/publish/TestWSMPublisher.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/edu/indiana/extreme/lead/workflow_tracking/messagebox/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/edu/indiana/extreme/lead/workflow_tracking/messagebox/MessagePullerTest.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/edu/indiana/extreme/lead/workflow_tracking/messagebox/MultipleSubscriptionForMessageBoxTest.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/edu/indiana/extreme/lead/workflow_tracking/messagebox/RenewSubscriptionTest.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/edu/indiana/extreme/lead/workflow_tracking/messagebox/SubscriberThread.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/edu/indiana/extreme/lead/workflow_tracking/messagebox/restart/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/edu/indiana/extreme/lead/workflow_tracking/messagebox/restart/MessageBoxClientRestartTest.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/edu/indiana/extreme/lead/workflow_tracking/messagebox/restart/MessageBoxCreateThread.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/edu/indiana/extreme/lead/workflow_tracking/samples/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/edu/indiana/extreme/lead/workflow_tracking/samples/workflow/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/edu/indiana/extreme/lead/workflow_tracking/samples/workflow/SimpleTest.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/edu/indiana/extreme/lead/workflow_tracking/samples/workflow/SimpleWorkflowExecution.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/edu/indiana/extreme/lead/workflow_tracking/samples/workflow/WorkflowNotificationListener.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/edu/indiana/extreme/lead/workflow_tracking/util/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/edu/indiana/extreme/lead/workflow_tracking/util/CommonUtils.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/edu/indiana/extreme/lead/workflow_tracking/util/SubscriberThread.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/java/edu/indiana/extreme/lead/workflow_tracking/util/TestConfigKeys.java
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/resources/
incubator/airavata/donations/ogce-donation/modules/ws-messaging/workflow-tracking/src/test/resources/unit_test.properties
Removed:
incubator/airavata/donations/ogce-donation/modules/ws-messaging/messagebox/
Added: incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/customLibs/activeMQ/amq.jar
URL: http://svn.apache.org/viewvc/incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/customLibs/activeMQ/amq.jar?rev=1142350&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/customLibs/activeMQ/amq.jar
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/customLibs/activeMQ/geronimo-spec-jms-1.1-rc4.jar
URL: http://svn.apache.org/viewvc/incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/customLibs/activeMQ/geronimo-spec-jms-1.1-rc4.jar?rev=1142350&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/customLibs/activeMQ/geronimo-spec-jms-1.1-rc4.jar
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/customLibs/util-concurrent.jar
URL: http://svn.apache.org/viewvc/incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/customLibs/util-concurrent.jar?rev=1142350&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/customLibs/util-concurrent.jar
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/customLibs/zFilter.jar
URL: http://svn.apache.org/viewvc/incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/customLibs/zFilter.jar?rev=1142350&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/customLibs/zFilter.jar
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/pom.xml
URL: http://svn.apache.org/viewvc/incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/pom.xml?rev=1142350&view=auto
==============================================================================
--- incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/pom.xml (added)
+++ incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/pom.xml Sun Jul 3 00:29:24 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>org.ogce.ws-messenger</groupId>
+ <version>1.1.1</version>
+ </parent>
+ <modelVersion>4.0.0</modelVersion>
+ <groupId>org.ogce.broker</groupId>
+ <artifactId>broker</artifactId>
+ <name>broker</name>
+ <url>http://ogce.sourceforge.net/</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>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/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/NotificationHandler.java
URL: http://svn.apache.org/viewvc/incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/NotificationHandler.java?rev=1142350&view=auto
==============================================================================
--- incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/NotificationHandler.java (added)
+++ incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/NotificationHandler.java Sun Jul 3 00:29:24 2011
@@ -0,0 +1,24 @@
+/*
+ * Licensed to the Lanka Software Foundation (LSF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The LSF 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 wsmg;
+
+public interface NotificationHandler {
+ public void handleNotification(String message);
+}
Added: incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/AbstractBrokerMsgReceiver.java
URL: http://svn.apache.org/viewvc/incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/AbstractBrokerMsgReceiver.java?rev=1142350&view=auto
==============================================================================
--- incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/AbstractBrokerMsgReceiver.java (added)
+++ incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/AbstractBrokerMsgReceiver.java Sun Jul 3 00:29:24 2011
@@ -0,0 +1,114 @@
+/*
+ * Licensed to the Lanka Software Foundation (LSF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The LSF 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 wsmg.broker;
+
+import java.util.List;
+
+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;
+
+import wsmg.broker.context.ProcessingContext;
+import wsmg.commons.WsmgNameSpaceConstants;
+
+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);
+ }
+
+ }
+
+}
Propchange: incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/AbstractBrokerMsgReceiver.java
------------------------------------------------------------------------------
svn:executable = *
Added: incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/AdditionalMessageContent.java
URL: http://svn.apache.org/viewvc/incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/AdditionalMessageContent.java?rev=1142350&view=auto
==============================================================================
--- incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/AdditionalMessageContent.java (added)
+++ incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/AdditionalMessageContent.java Sun Jul 3 00:29:24 2011
@@ -0,0 +1,132 @@
+/*
+ * Licensed to the Lanka Software Foundation (LSF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The LSF 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 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/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/BrokerServiceLifeCycle.java
URL: http://svn.apache.org/viewvc/incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/BrokerServiceLifeCycle.java?rev=1142350&view=auto
==============================================================================
--- incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/BrokerServiceLifeCycle.java (added)
+++ incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/BrokerServiceLifeCycle.java Sun Jul 3 00:29:24 2011
@@ -0,0 +1,246 @@
+/*
+ * Licensed to the Lanka Software Foundation (LSF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The LSF 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 wsmg.broker;
+
+import java.util.Iterator;
+import java.util.List;
+
+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;
+
+import wsmg.broker.handler.PublishedMessageHandler;
+import wsmg.broker.subscription.SubscriptionManager;
+import wsmg.commons.WsmgCommonConstants;
+import wsmg.commons.storage.WsmgInMemoryStorage;
+import wsmg.commons.storage.WsmgPersistantStorage;
+import wsmg.commons.storage.WsmgStorage;
+import wsmg.config.ConfigurationManager;
+import wsmg.config.WSMGParameter;
+import wsmg.config.WsmgConfigurationContext;
+import wsmg.messenger.ConsumerUrlManager;
+import wsmg.messenger.strategy.SendingStrategy;
+import wsmg.messenger.strategy.impl.FixedParallelSender;
+import wsmg.messenger.strategy.impl.ParallelSender;
+import wsmg.messenger.strategy.impl.SerialSender;
+import wsmg.util.RunTimeStatistics;
+
+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");
+ }
+
+ }
+
+}
\ No newline at end of file
Added: incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/ConsumerInfo.java
URL: http://svn.apache.org/viewvc/incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/ConsumerInfo.java?rev=1142350&view=auto
==============================================================================
--- incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/ConsumerInfo.java (added)
+++ incubator/airavata/donations/ogce-donation/modules/ws-messaging/broker/src/main/java/wsmg/broker/ConsumerInfo.java Sun Jul 3 00:29:24 2011
@@ -0,0 +1,122 @@
+/*
+ * Licensed to the Lanka Software Foundation (LSF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The LSF 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 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;
+ }
+
+}