Permalink
Browse files

BZ852231 - BRMS AsyncWSHumanTaskHandler port conflicts with JON port …

…configuration
  • Loading branch information...
1 parent 16ab55c commit 2d94f3228ad89c2fe77d4123382ddbc9e4242ceb @mswiderski mswiderski committed Oct 30, 2012
Showing with 81 additions and 81 deletions.
  1. +1 −1 jbpm-docs/src/main/docbook/en-US/Chapter-Console/Chapter-Console.xml
  2. +2 −2 jbpm-docs/src/main/docbook/en-US/Chapter-HumanTasks/Chapter-HumanTasks.xml
  3. +1 −1 jbpm-examples/src/main/java/org/jbpm/examples/evaluation/EvaluationExample2.java
  4. +1 −1 jbpm-examples/src/main/java/org/jbpm/examples/humantask/HumanTaskExample.java
  5. +1 −1 jbpm-examples/src/main/java/org/jbpm/examples/multipleinstance/MultipleInstanceExample.java
  6. +1 −1 jbpm-gwt/jbpm-gwt-console-server/src/main/resources/default.jbpm.console.properties
  7. +2 −2 jbpm-gwt/jbpm-gwt-core/src/main/java/org/jbpm/integration/console/Utils.java
  8. +1 −1 jbpm-gwt/jbpm-gwt-core/src/test/java/org/jbpm/integration/JbpmGwtCoreTestCase.java
  9. +1 −1 jbpm-gwt/jbpm-gwt-core/src/test/resources/default.jbpm.console.properties
  10. +1 −1 ...uman-task-hornetq/src/main/java/org/jbpm/process/workitem/wsht/AsyncHornetQHTWorkItemHandler.java
  11. +1 −1 ...bpm-human-task-hornetq/src/main/java/org/jbpm/process/workitem/wsht/HornetQHTWorkItemHandler.java
  12. +1 −1 ...sk-hornetq/src/main/java/org/jbpm/task/service/hornetq/CommandBasedHornetQWSHumanTaskHandler.java
  13. +1 −1 ...pm-human-task-hornetq/src/main/java/org/jbpm/task/service/hornetq/HornetQTaskClientConnector.java
  14. +2 −2 ...n-task-hornetq/src/test/java/org/jbpm/process/workitem/wsht/hornetq/HornetQErrorRecoveryTest.java
  15. +1 −1 ...ask-hornetq/src/test/java/org/jbpm/process/workitem/wsht/hornetq/HornetQMultipleHandlersTest.java
  16. +1 −1 ...t/java/org/jbpm/process/workitem/wsht/hornetq/WSHumanTaskHandlerHornetQUserGroupCallbackTest.java
  17. +1 −1 ...src/test/java/org/jbpm/process/workitem/wsht/hornetq/async/AsyncHornetQHTWorkItemHandlerTest.java
  18. +1 −1 ...rc/test/java/org/jbpm/process/workitem/wsht/hornetq/async/WSHumanTaskHandlerHornetQAsyncTest.java
  19. +1 −1 ...rnetq/src/test/java/org/jbpm/process/workitem/wsht/hornetq/sync/HornetQHTWorkItemHandlerTest.java
  20. +1 −1 .../src/test/java/org/jbpm/process/workitem/wsht/hornetq/sync/WSHumanTaskHandlerHornetQSyncTest.java
  21. +2 −2 ...ask-hornetq/src/test/java/org/jbpm/task/service/hornetq/async/ClaimTaskTwiceHornetQAsyncTest.java
  22. +2 −2 ...pm-human-task-hornetq/src/test/java/org/jbpm/task/service/hornetq/async/IcalHornetQAsyncTest.java
  23. +2 −2 ...task-hornetq/src/test/java/org/jbpm/task/service/hornetq/async/TaskLifeCycleHornetQAsyncTest.java
  24. +2 −2 ...t/java/org/jbpm/task/service/hornetq/async/TaskServiceCommentsAndAttachmentsHornetQAsyncTest.java
  25. +2 −2 ...ask/service/hornetq/async/TaskServiceCommentsAndAttachmentsHornetQUserGroupCallbackAsyncTest.java
  26. +2 −2 ...rnetq/src/test/java/org/jbpm/task/service/hornetq/async/TaskServiceDeadlinesHornetQAsyncTest.java
  27. +2 −2 ...va/org/jbpm/task/service/hornetq/async/TaskServiceDeadlinesHornetQUserGroupCallbackAsyncTest.java
  28. +2 −2 ...netq/src/test/java/org/jbpm/task/service/hornetq/async/TaskServiceEscalationHornetQAsyncTest.java
  29. +2 −2 ...a/org/jbpm/task/service/hornetq/async/TaskServiceEscalationHornetQUserGroupCallbackAsyncTest.java
  30. +2 −2 .../src/test/java/org/jbpm/task/service/hornetq/async/TaskServiceEventMessagingHornetQAsyncTest.java
  31. +2 −2 ...n-task-hornetq/src/test/java/org/jbpm/task/service/hornetq/async/TaskServiceHornetQAsyncTest.java
  32. +2 −2 ...c/test/java/org/jbpm/task/service/hornetq/async/TaskServiceHornetQUserGroupCallbackAsyncTest.java
  33. +2 −2 ...rnetq/src/test/java/org/jbpm/task/service/hornetq/async/TaskServiceLifeCycleHornetQAsyncTest.java
  34. +2 −2 ...va/org/jbpm/task/service/hornetq/async/TaskServiceLifeCycleHornetQUserGroupCallbackAsyncTest.java
  35. +2 −2 .../src/test/java/org/jbpm/task/service/hornetq/async/TaskServiceTaskAttributesHornetQAsyncTest.java
  36. +2 −2 ...g/jbpm/task/service/hornetq/async/TaskServiceTaskAttributesHornetQUserGroupCallbackAsyncTest.java
  37. +2 −2 ...est/java/org/jbpm/task/service/hornetq/persistence/EventPersistenceServerSideHornetQSyncTest.java
  38. +2 −2 ...jbpm-human-task-hornetq/src/test/java/org/jbpm/task/service/hornetq/sync/IcalHornetQSyncTest.java
  39. +2 −2 ...n-task-hornetq/src/test/java/org/jbpm/task/service/hornetq/sync/TaskLifeCycleHornetQSyncTest.java
  40. +2 −2 ...est/java/org/jbpm/task/service/hornetq/sync/TaskServiceCommentsAndAttachmentsHornetQSyncTest.java
  41. +2 −2 ...hornetq/src/test/java/org/jbpm/task/service/hornetq/sync/TaskServiceDeadlinesHornetQSyncTest.java
  42. +2 −2 ...ornetq/src/test/java/org/jbpm/task/service/hornetq/sync/TaskServiceEscalationHornetQSyncTest.java
  43. +2 −2 ...hornetq/src/test/java/org/jbpm/task/service/hornetq/sync/TaskServiceLifeCycleHornetQSyncTest.java
  44. +2 −2 ...tq/src/test/java/org/jbpm/task/service/hornetq/sync/TaskServiceTaskAttributesHornetQSyncTest.java
  45. +1 −1 jbpm-human-task/jbpm-human-task-war/src/main/java/org/jbpm/task/servlet/HumanTaskServiceServlet.java
  46. +6 −6 ...man-task/jbpm-human-task-war/src/test/java/org/jbpm/task/servlet/HumanTaskServiceSerlvetTest.java
  47. +1 −1 jbpm-installer/conf/default.jbpm.console.properties
  48. +1 −1 jbpm-installer/sample/evaluation/src/main/java/com/sample/ProcessTest.java
  49. +1 −1 jbpm-test/src/main/java/org/jbpm/test/JBPMHelper.java
@@ -151,7 +151,7 @@
<itemizedlist>
<listitem>jbpm.console.task.service.strategy : transport used to connect to task server (default HornetQ and accepts Mina|HornetQ|JMS)</listitem>
<listitem>jbpm.console.task.service.host : host where Task Server is deployed (default localhost) applies to all transports</listitem>
- <listitem>jbpm.console.task.service.port : port where Task Server is deployed (default 5445) applies to all transports</listitem>
+ <listitem>jbpm.console.task.service.port : port where Task Server is deployed (default 5153) applies to all transports</listitem>
<listitem>JMSTaskClient.connectionFactory : JNDI name of connection factory only for JMS (no default)</listitem>
<listitem>JMSTaskClient.acknowledgeMode : acknowledgment mode only for JMS (no default)</listitem>
<listitem>JMSTaskClient.transactedQueue : transacted queue name only for JMS (no default)</listitem>
@@ -575,7 +575,7 @@
ksession.getWorkItemManager().registerWorkItemHandler("Human Task", new AsyncHornetQHTWorkItemHandler(ksession));</programlisting>
<para>By default, this handler will connect to the human task service on the local
- machine on port 5445 via hornetq. You can easily change connection details of the human task
+ machine on port 5153 via hornetq. You can easily change connection details of the human task
service by either building TaskClient yourself and pass it as handler constructor argument
or by setting ip address and port number after handler is created.</para>
@@ -1167,7 +1167,7 @@ ldap.entity.id.dn=true
HornetQ
<itemizedlist>
<listitem>hornetq.host : host/ip address used to bind HornetQ server (default localhost)</listitem>
- <listitem>hornetq.port : port used to bind HornetQ server (default 5445)</listitem>
+ <listitem>hornetq.port : port used to bind HornetQ server (default 5153)</listitem>
</itemizedlist>
JMS
<itemizedlist>
@@ -42,7 +42,7 @@ public static final void main(String[] args) {
SystemEventListenerFactory.setSystemEventListener(new SystemEventListener());
TaskService taskClient = new SyncTaskServiceWrapper(new AsyncHornetQTaskClient("EvaluationExample2-testClient"));
- taskClient.connect("127.0.0.1", 5445);
+ taskClient.connect("127.0.0.1", 5153);
Thread.sleep(1000);
@@ -45,7 +45,7 @@ public static final void main(String[] args) {
// we can reuse the client used by the Work Item Hander.
TaskService taskClient = new SyncTaskServiceWrapper(new AsyncHornetQTaskClient("HumanTaskExample-testClient"));
- taskClient.connect("127.0.0.1", 5445);
+ taskClient.connect("127.0.0.1", 5153);
Thread.sleep(1000);
// "sales-rep" reviews request
@@ -25,7 +25,7 @@ public static final void main(String[] args) {
StatefulKnowledgeSession ksession = kbase.newStatefulKnowledgeSession();
KnowledgeRuntimeLogger logger = KnowledgeRuntimeLoggerFactory.newThreadedFileLogger(ksession, "test", 1000);
HornetQHTWorkItemHandler hornetQHTWorkItemHandler = new HornetQHTWorkItemHandler(ksession);
- hornetQHTWorkItemHandler.setPort(5445);
+ hornetQHTWorkItemHandler.setPort(5153);
ksession.getWorkItemManager().registerWorkItemHandler("Human Task", hornetQHTWorkItemHandler);
// start a new process instance
@@ -2,7 +2,7 @@ jbpm.console.server.host=localhost
jbpm.console.server.port=8080
jbpm.console.task.service.strategy=HornetQ
jbpm.console.task.service.host=127.0.0.1
-jbpm.console.task.service.port=5445
+jbpm.console.task.service.port=5153
jbpm.console.directory=
guvnor.protocol=http
guvnor.host=localhost:8080
@@ -21,7 +21,7 @@
public static final String DEFAULT_TASK_SERVICE_STRATEGY = "HornetQ";
public static final String DEFAULT_IP_ADDRESS = "127.0.0.1";
- public static final int DEFAULT_PORT = 5445;
+ public static final int DEFAULT_PORT = 5153;
public static String getTaskServiceHost(Properties properties) {
String host = properties.getProperty("jbpm.console.task.service.host", DEFAULT_IP_ADDRESS);
@@ -36,7 +36,7 @@ public static int getTaskServicePort(Properties properties) {
defaultPort = "9123";
} else if ("HornetQ".equalsIgnoreCase(strategy)) {
- defaultPort = "5445";
+ defaultPort = "5153";
}
String port = properties.getProperty("jbpm.console.task.service.port", defaultPort);
@@ -78,7 +78,7 @@ protected static void startHumanTaskServer(){
}
// start server
- minaServer = new HornetQTaskServer(taskService, 5445);
+ minaServer = new HornetQTaskServer(taskService, 5153);
minaServerThread = new Thread(minaServer);
minaServerThread.start();
taskSession.dispose();
@@ -5,7 +5,7 @@ jbpm.console.server.context=gwt-console-server
#jbpm.console.task.service.strategy=Mina|HornetQ|JMS|Local default to Mina
jbpm.console.task.service.strategy=HornetQ
jbpm.console.task.service.host=127.0.0.1
-jbpm.console.task.service.port=5445
+jbpm.console.task.service.port=5153
jbpm.console.directory=
guvnor.protocol=http
guvnor.host=localhost:8080
@@ -71,7 +71,7 @@ private void init(){
setClient(new AsyncHornetQTaskClient(this.connectorName));
}
if(getPort() <= 0){
- setPort(5445);
+ setPort(5153);
}
if(getIpAddress() == null || getIpAddress().equals("")){
setIpAddress("127.0.0.1");
@@ -75,7 +75,7 @@ private void init(){
setClient(new SyncTaskServiceWrapper(new AsyncHornetQTaskClient(this.connectorName)));
}
if(getPort() <= 0){
- setPort(5445);
+ setPort(5153);
}
if(getIpAddress() == null || getIpAddress().equals("")){
setIpAddress("127.0.0.1");
@@ -63,7 +63,7 @@
private static final Logger logger = LoggerFactory.getLogger(CommandBasedHornetQWSHumanTaskHandler.class);
private String ipAddress = "127.0.0.1";
- private int port = 5445;
+ private int port = 5153;
private TaskClient client;
private KnowledgeRuntime session;
@@ -86,7 +86,7 @@ public boolean connect() {
address = "127.0.0.1";
}
if (port==null) {
- port = 5445;
+ port = 5153;
}
connectionParams.put(TransportConstants.PORT_PROP_NAME, port);
connectionParams.put(TransportConstants.HOST_PROP_NAME, address);
@@ -39,7 +39,7 @@
@Override
protected void setUp() throws Exception {
super.setUp();
- server = new HornetQTaskServer(taskService, 5445);
+ server = new HornetQTaskServer(taskService, 5153);
System.out.println("Waiting for the HornetQTask Server to come up");
try {
startTaskServerThread(server, false);
@@ -120,7 +120,7 @@ public void testRecoveryOfLostConnectionToTaskServer() throws Exception {
server.stop();
- server = new HornetQTaskServer(taskService, 5445);
+ server = new HornetQTaskServer(taskService, 5153);
System.out.println("Waiting for the HornetQTask Server to come up");
try {
startTaskServerThread(server, false);
@@ -44,7 +44,7 @@
@Override
protected void setUp() throws Exception {
super.setUp();
- server = new HornetQTaskServer(taskService, 5445);
+ server = new HornetQTaskServer(taskService, 5153);
System.out.println("Waiting for the HornetQTask Server to come up");
try {
startTaskServerThread(server, false);
@@ -28,7 +28,7 @@
@Override
protected void setUp() throws Exception {
super.setUp();
- server = new HornetQTaskServer(taskService, 5445);
+ server = new HornetQTaskServer(taskService, 5153);
System.out.println("Waiting for the HornetQTask Server to come up");
try {
startTaskServerThread(server, false);
@@ -27,7 +27,7 @@
@Override
protected void setUp() throws Exception {
super.setUp();
- server = new HornetQTaskServer(taskService, 5445);
+ server = new HornetQTaskServer(taskService, 5153);
System.out.println("Waiting for the HornetQTask Server to come up");
try {
startTaskServerThread(server, false);
@@ -28,7 +28,7 @@
@Override
protected void setUp() throws Exception {
super.setUp();
- server = new HornetQTaskServer(taskService, 5445);
+ server = new HornetQTaskServer(taskService, 5153);
System.out.println("Waiting for the HornetQTask Server to come up");
try {
startTaskServerThread(server, false);
@@ -27,7 +27,7 @@
@Override
protected void setUp() throws Exception {
super.setUp();
- server = new HornetQTaskServer(taskService, 5445);
+ server = new HornetQTaskServer(taskService, 5153);
System.out.println("Waiting for the HornetQTask Server to come up");
try {
startTaskServerThread(server, false);
@@ -29,7 +29,7 @@
@Override
protected void setUp() throws Exception {
super.setUp();
- server = new HornetQTaskServer(taskService, 5445);
+ server = new HornetQTaskServer(taskService, 5153);
System.out.println("Waiting for the HornetQTask Server to come up");
try {
startTaskServerThread(server, false);
@@ -37,7 +37,7 @@ protected void setUp() throws Exception {
super.setUp();
// HornetQ setup
- server = new HornetQTaskServer(taskService, 5445);
+ server = new HornetQTaskServer(taskService, 5153);
System.out.println("Waiting for the HornetQTask Server to come up");
try {
startTaskServerThread(server, false);
@@ -53,7 +53,7 @@ protected void tearDown() throws Exception {
protected TaskService createClient(String clientName) {
TaskClient taskClient = new AsyncHornetQTaskClient();
- taskClient.connect("127.0.0.1", 5445);
+ taskClient.connect("127.0.0.1", 5153);
TaskService client = new SyncTaskServiceWrapper(taskClient);
return client;
@@ -35,7 +35,7 @@ protected void setUp() throws Exception {
setEmailHost(props.getProperty("host", "locahost"));
setEmailPort(props.getProperty("port", "2345"));
- server = new HornetQTaskServer(taskService, 5445);
+ server = new HornetQTaskServer(taskService, 5153);
System.out.println("Waiting for the HornetQTask Server to come up");
try {
startTaskServerThread(server, false);
@@ -44,7 +44,7 @@ protected void setUp() throws Exception {
}
client = new AsyncHornetQTaskClient();
- client.connect("127.0.0.1", 5445);
+ client.connect("127.0.0.1", 5153);
setWiser(new Wiser());
getWiser().setHostname(getEmailHost());
@@ -25,15 +25,15 @@
@Override
protected void setUp() throws Exception {
super.setUp();
- server = new HornetQTaskServer(taskService, 5445);
+ server = new HornetQTaskServer(taskService, 5153);
System.out.println("Waiting for the HornetQTask Server to come up");
try {
startTaskServerThread(server, false);
} catch (Exception e) {
startTaskServerThread(server, true);
}
client = new AsyncHornetQTaskClient();
- client.connect("127.0.0.1", 5445);
+ client.connect("127.0.0.1", 5153);
}
}
@@ -25,7 +25,7 @@
@Override
protected void setUp() throws Exception {
super.setUp();
- server = new HornetQTaskServer(taskService, 5445);
+ server = new HornetQTaskServer(taskService, 5153);
System.out.println("Waiting for the HornetQTask Server to come up");
try {
startTaskServerThread(server, false);
@@ -34,6 +34,6 @@ protected void setUp() throws Exception {
}
client = new AsyncHornetQTaskClient();
- client.connect("127.0.0.1", 5445);
+ client.connect("127.0.0.1", 5153);
}
}
@@ -26,7 +26,7 @@
@Override
protected void setUp() throws Exception {
super.setUp();
- server = new HornetQTaskServer(taskService, 5445);
+ server = new HornetQTaskServer(taskService, 5153);
System.out.println("Waiting for the HornetQTask Server to come up");
try {
startTaskServerThread(server, false);
@@ -35,7 +35,7 @@ protected void setUp() throws Exception {
}
client = new AsyncHornetQTaskClient();
- client.connect("127.0.0.1", 5445);
+ client.connect("127.0.0.1", 5153);
}
@@ -36,7 +36,7 @@ protected void setUp() throws Exception {
getConf().setProperty("replyTo", "replyTo@domain.com");
getConf().setProperty("defaultLanguage", "en-UK");
- server = new HornetQTaskServer(taskService, 5445);
+ server = new HornetQTaskServer(taskService, 5153);
System.out.println("Waiting for the HornetQTask Server to come up");
try {
startTaskServerThread(server, false);
@@ -45,7 +45,7 @@ protected void setUp() throws Exception {
}
client = new AsyncHornetQTaskClient();
- client.connect("127.0.0.1", 5445);
+ client.connect("127.0.0.1", 5153);
setWiser(new Wiser());
getWiser().setHostname(getConf().getProperty("mail.smtp.host"));
@@ -37,7 +37,7 @@ protected void setUp() throws Exception {
getConf().setProperty("replyTo", "replyTo@domain.com");
getConf().setProperty("defaultLanguage", "en-UK");
- server = new HornetQTaskServer(taskService, 5445);
+ server = new HornetQTaskServer(taskService, 5153);
System.out.println("Waiting for the HornetQTask Server to come up");
try {
startTaskServerThread(server, false);
@@ -46,7 +46,7 @@ protected void setUp() throws Exception {
}
client = new AsyncHornetQTaskClient();
- client.connect("127.0.0.1", 5445);
+ client.connect("127.0.0.1", 5153);
setWiser(new Wiser());
getWiser().setHostname(getConf().getProperty("mail.smtp.host"));
@@ -25,7 +25,7 @@
@Override
protected void setUp() throws Exception {
super.setUp();
- server = new HornetQTaskServer(taskService, 5445);
+ server = new HornetQTaskServer(taskService, 5153);
System.out.println("Waiting for the HornetQTask Server to come up");
try {
startTaskServerThread(server, false);
@@ -34,7 +34,7 @@ protected void setUp() throws Exception {
}
client = new AsyncHornetQTaskClient();
- client.connect("127.0.0.1", 5445);
+ client.connect("127.0.0.1", 5153);
}
}
@@ -27,7 +27,7 @@
@Override
protected void setUp() throws Exception {
super.setUp();
- server = new HornetQTaskServer(taskService, 5445);
+ server = new HornetQTaskServer(taskService, 5153);
System.out.println("Waiting for the HornetQTask Server to come up");
try {
startTaskServerThread(server, false);
@@ -36,7 +36,7 @@ protected void setUp() throws Exception {
}
client = new AsyncHornetQTaskClient();
- client.connect("127.0.0.1", 5445);
+ client.connect("127.0.0.1", 5153);
}
}
@@ -26,7 +26,7 @@
@Override
protected void setUp() throws Exception {
super.setUp();
- server = new HornetQTaskServer(taskService, 5445);
+ server = new HornetQTaskServer(taskService, 5153);
System.out.println("Waiting for the HornetQTask Server to come up");
try {
startTaskServerThread(server, false);
@@ -35,7 +35,7 @@ protected void setUp() throws Exception {
}
client = new AsyncHornetQTaskClient();
- client.connect("127.0.0.1", 5445);
+ client.connect("127.0.0.1", 5153);
MockUserInfo userInfo = new MockUserInfo();
userInfo.getEmails().put(users.get("tony"), "tony@domain.com");
Oops, something went wrong.

0 comments on commit 2d94f32

Please sign in to comment.