Repository: oodt Updated Branches: refs/heads/avro_rpc fe0cf528c -> 06a8a1e1c
add more logging Project: http://git-wip-us.apache.org/repos/asf/oodt/repo Commit: http://git-wip-us.apache.org/repos/asf/oodt/commit/06a8a1e1 Tree: http://git-wip-us.apache.org/repos/asf/oodt/tree/06a8a1e1 Diff: http://git-wip-us.apache.org/repos/asf/oodt/diff/06a8a1e1 Branch: refs/heads/avro_rpc Commit: 06a8a1e1c3bd8a0391d2be83c687668ab728567a Parents: fe0cf52 Author: Tom Barber <[email protected]> Authored: Wed Jul 6 21:37:43 2016 +0100 Committer: Tom Barber <[email protected]> Committed: Wed Jul 6 21:37:43 2016 +0100 ---------------------------------------------------------------------- .../oodt/cas/workflow/system/AvroRpcWorkflowManager.java | 8 +++++++- .../oodt/cas/workflow/system/TestAvroRpcWorkflowManager.java | 3 --- 2 files changed, 7 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/oodt/blob/06a8a1e1/workflow/src/main/java/org/apache/oodt/cas/workflow/system/AvroRpcWorkflowManager.java ---------------------------------------------------------------------- diff --git a/workflow/src/main/java/org/apache/oodt/cas/workflow/system/AvroRpcWorkflowManager.java b/workflow/src/main/java/org/apache/oodt/cas/workflow/system/AvroRpcWorkflowManager.java index 5f81b98..8cb8922 100644 --- a/workflow/src/main/java/org/apache/oodt/cas/workflow/system/AvroRpcWorkflowManager.java +++ b/workflow/src/main/java/org/apache/oodt/cas/workflow/system/AvroRpcWorkflowManager.java @@ -86,18 +86,24 @@ public class AvroRpcWorkflowManager implements WorkflowManager,org.apache.oodt.c } public AvroRpcWorkflowManager(int port){ + LOG.log(Level.INFO, "Starting workflow manager on port: "+port+" as " + + System.getProperty("user.name", "unknown")); Preconditions.checkArgument(port > 0, "Must specify a port greater than 0"); webServerPort = port; - + LOG.log(Level.INFO, "Getting workflow engine"); engine = getWorkflowEngineFromProperty(); + LOG.log(Level.INFO, "Setting workflow engine url:"+safeGetUrlFromString("http://"; + + getHostname() + ":" + this.webServerPort).toString()); engine.setWorkflowManagerUrl(safeGetUrlFromString("http://"; + getHostname() + ":" + this.webServerPort)); repo = getWorkflowRepositoryFromProperty(); + LOG.log(Level.INFO, "Starting Netty Server"); // start up the server server = new NettyServer(new SpecificResponder( org.apache.oodt.cas.workflow.struct.avrotypes.WorkflowManager.class,this), new InetSocketAddress(this.webServerPort)); + LOG.log(Level.INFO, "GOOOOO!"); server.start(); LOG.log(Level.INFO, "Workflow Manager started by " + System.getProperty("user.name", "unknown")); http://git-wip-us.apache.org/repos/asf/oodt/blob/06a8a1e1/workflow/src/test/java/org/apache/oodt/cas/workflow/system/TestAvroRpcWorkflowManager.java ---------------------------------------------------------------------- diff --git a/workflow/src/test/java/org/apache/oodt/cas/workflow/system/TestAvroRpcWorkflowManager.java b/workflow/src/test/java/org/apache/oodt/cas/workflow/system/TestAvroRpcWorkflowManager.java index 33226a2..d68b832 100644 --- a/workflow/src/test/java/org/apache/oodt/cas/workflow/system/TestAvroRpcWorkflowManager.java +++ b/workflow/src/test/java/org/apache/oodt/cas/workflow/system/TestAvroRpcWorkflowManager.java @@ -103,7 +103,6 @@ public class TestAvroRpcWorkflowManager extends TestCase { FileInputStream fileInputStream = new FileInputStream(ulr.getPath()); System.getProperties().load( fileInputStream); - System.setProperty("org.apache.oodt.cas.workflow.instanceRep.lucene.idxPath", System.getProperty("java.io.tmpdir")+"/repo"); } catch (Exception e) { e.printStackTrace(); @@ -156,6 +155,4 @@ public class TestAvroRpcWorkflowManager extends TestCase { } } - - }
