You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sh...@apache.org on 2016/08/09 22:19:42 UTC
[4/4] airavata git commit: Merge branch 'messaging-refactor' into
develop
Merge branch 'messaging-refactor' into develop
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/20b3d251
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/20b3d251
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/20b3d251
Branch: refs/heads/develop
Commit: 20b3d251a2ab6d0c97e4460b5743de8a9655db04
Parents: 4157065 e247b00
Author: Shameera Rathnayaka <sh...@gmail.com>
Authored: Tue Aug 9 18:19:22 2016 -0400
Committer: Shameera Rathnayaka <sh...@gmail.com>
Committed: Tue Aug 9 18:19:22 2016 -0400
----------------------------------------------------------------------
.../airavata/common/utils/ServerSettings.java | 42 +-
.../main/resources/airavata-server.properties | 12 +-
.../org/apache/airavata/gfac/impl/Factory.java | 26 +-
.../apache/airavata/gfac/impl/GFacWorker.java | 3 +-
.../airavata/gfac/server/GfacServerHandler.java | 82 +--
.../messaging/client/RabbitMQListener.java | 258 +++++----
.../airavata/messaging/core/Consumer.java | 40 --
.../airavata/messaging/core/MessageHandler.java | 4 +-
.../messaging/core/MessagingConstants.java | 3 +-
.../messaging/core/MessagingFactory.java | 88 +++
.../airavata/messaging/core/Metadata.java | 25 -
.../airavata/messaging/core/Publisher.java | 1 +
.../airavata/messaging/core/Subscriber.java | 58 ++
.../messaging/core/SubscriberProperties.java | 125 ++++
.../airavata/messaging/core/TestClient.java | 56 +-
.../messaging/core/impl/ExperimentConsumer.java | 42 ++
.../messaging/core/impl/ProcessConsumer.java | 114 ++++
.../impl/RabbitMQProcessLaunchConsumer.java | 574 +++++++++----------
.../impl/RabbitMQProcessLaunchPublisher.java | 2 +-
.../core/impl/RabbitMQStatusConsumer.java | 286 ---------
.../core/impl/RabbitMQStatusSubscriber.java | 287 ++++++++++
.../messaging/core/impl/RabbitMQSubscriber.java | 189 ++++++
.../messaging/core/impl/StatusConsumer.java | 143 +++++
.../server/OrchestratorServerHandler.java | 47 +-
.../ExperimentExecution.java | 391 +++++++------
.../workflow/core/WorkflowEnactmentService.java | 60 +-
.../workflow/core/WorkflowInterpreter.java | 21 +-
27 files changed, 1831 insertions(+), 1148 deletions(-)
----------------------------------------------------------------------