[JBoss JIRA] (JGRP-2263) JGRP000225: failed unmarshalling buffer into return value
by Bela Ban (JIRA)
[ https://issues.jboss.org/browse/JGRP-2263?page=com.atlassian.jira.plugin.... ]
Bela Ban updated JGRP-2263:
---------------------------
Steps to Reproduce:
{code:java}
public class SimpleChat {
JChannel channel;
RpcDispatcher dispatcher;
private static final RequestOptions IMPORTANT = new RequestOptions(ResponseMode.GET_ALL, TimeUnit.SECONDS.toMillis(60)).setFlags(Message.Flag.DONT_BUNDLE);
private void start() throws Exception {
channel = new JChannel();
dispatcher = new RpcDispatcher(channel, new Test() {
});
channel.connect("ChatCluster");
channel.getState(null, 10000);
Method test = Test.class.getMethod("test");
Object o = dispatcher.callRemoteMethods(null, new MethodCall(test), IMPORTANT);
System.out.println(o);
channel.close();
}
public static void main(String[] args) throws Exception {
new SimpleChat().start();
}
public static class Test {
public Object test() {
return new EError(EError.EErrorKind.WRONG_PARAMS);
}
}
public static class EError extends Error {
private static final long serialVersionUID = 1L;
enum EErrorKind {
WRONG_PARAMS,
}
final EErrorKind code;
public EError(EError.EErrorKind code) {
this.code = code;
}
}
}
{code}
was:
{code:java}
public class SimpleChat {
JChannel channel;
RpcDispatcher dispatcher;
private static final RequestOptions IMPORTANT = new RequestOptions(ResponseMode.GET_ALL, TimeUnit.SECONDS.toMillis(60)).setFlags(Message.Flag.DONT_BUNDLE);
private void start() throws Exception {
channel = new JChannel();
dispatcher = new RpcDispatcher(channel, new Test() {
});
channel.connect("ChatCluster");
channel.getState(null, 10000);
Method test = Test.class.getMethod("test");
Object o = dispatcher.callRemoteMethods(null, new MethodCall(test), IMPORTANT);
System.out.println(o);
channel.close();
}
public static void main(String[] args) throws Exception {
new SimpleChat().start();
}
public static class Test {
public Object test() {
return new EError(EError.EErrorKind.WRONG_PARAMS);
}
}
public static class EError extends Error {
private static final long serialVersionUID = 1L;
enum EErrorKind {
WRONG_PARAMS,
}
final EErrorKind code;
public EError(EError.EErrorKind code) {
this.code = code;
}
}
}
{code}
> JGRP000225: failed unmarshalling buffer into return value
> ---------------------------------------------------------
>
> Key: JGRP-2263
> URL: https://issues.jboss.org/browse/JGRP-2263
> Project: JGroups
> Issue Type: Bug
> Affects Versions: 4.0.11
> Environment: jdk1.8.0_66.jdk
> osx 10.10 & ubuntu 17.10
> Reporter: rama rama
> Assignee: Bela Ban
> Fix For: 4.0.12
>
> Attachments: SimpleChat.java
>
>
> trying to send a class that previous work with 3.x return
> "failed unmarshalling buffer into return value"
> jgroups instance it's configured with the default settings
> i create a test case to reproduce it, executing this class on my 2 boxes return
> ----
> GRAVE: JGRP000225: failed unmarshalling buffer into return value
> java.lang.InstantiationException: com.eg.util.comm.SimpleChat$EError
> at java.lang.Class.newInstance(Class.java:427)
> at org.jgroups.util.Util.readException(Util.java:899)
> at org.jgroups.util.Util.exceptionFromStream(Util.java:843)
> at org.jgroups.util.Util.exceptionFromStream(Util.java:831)
> at org.jgroups.util.Util.objectFromStream(Util.java:782)
> at org.jgroups.util.Util.objectFromStream(Util.java:742)
> at org.jgroups.blocks.RequestCorrelator.replyFromBuffer(RequestCorrelator.java:463)
> at org.jgroups.blocks.RequestCorrelator.handleResponse(RequestCorrelator.java:408)
> at org.jgroups.blocks.RequestCorrelator.dispatch(RequestCorrelator.java:363)
> at org.jgroups.blocks.RequestCorrelator.receiveMessageBatch(RequestCorrelator.java:326)
> at org.jgroups.blocks.MessageDispatcher$ProtocolAdapter.up(MessageDispatcher.java:589)
> at org.jgroups.JChannel.up(JChannel.java:837)
> at org.jgroups.stack.ProtocolStack.up(ProtocolStack.java:896)
> at org.jgroups.stack.Protocol.up(Protocol.java:372)
> at org.jgroups.protocols.RSVP.up(RSVP.java:233)
> at org.jgroups.protocols.FRAG2.up(FRAG2.java:196)
> at org.jgroups.protocols.FlowControl.up(FlowControl.java:416)
> at org.jgroups.protocols.FlowControl.up(FlowControl.java:416)
> at org.jgroups.stack.Protocol.up(Protocol.java:372)
> at org.jgroups.protocols.pbcast.STABLE.up(STABLE.java:293)
> at org.jgroups.protocols.UNICAST3.deliverBatch(UNICAST3.java:1024)
> at org.jgroups.protocols.UNICAST3.removeAndDeliver(UNICAST3.java:833)
> at org.jgroups.protocols.UNICAST3.handleBatchFromSelf(UNICAST3.java:520)
> at org.jgroups.protocols.UNICAST3.up(UNICAST3.java:435)
> at org.jgroups.protocols.pbcast.NAKACK2.up(NAKACK2.java:697)
> at org.jgroups.protocols.BARRIER.up(BARRIER.java:195)
> at org.jgroups.stack.Protocol.up(Protocol.java:372)
> at org.jgroups.protocols.FD_ALL.up(FD_ALL.java:212)
> at org.jgroups.stack.Protocol.up(Protocol.java:372)
> at org.jgroups.stack.Protocol.up(Protocol.java:372)
> at org.jgroups.stack.Protocol.up(Protocol.java:372)
> at org.jgroups.protocols.TP.passBatchUp(TP.java:1274)
> at org.jgroups.util.MaxOneThreadPerSender$BatchHandlerLoop.passBatchUp(MaxOneThreadPerSender.java:284)
> at org.jgroups.util.SubmitToThreadPool$BatchHandler.run(SubmitToThreadPool.java:136)
> at org.jgroups.util.MaxOneThreadPerSender$BatchHandlerLoop.run(MaxOneThreadPerSender.java:273)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> at java.lang.Thread.run(Thread.java:745)
> Caused by: java.lang.NoSuchMethodException: com.eg.util.comm.SimpleChat$EError.<init>()
> at java.lang.Class.getConstructor0(Class.java:3082)
> at java.lang.Class.newInstance(Class.java:412)
> ... 37 more
> -----
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
8 years
[JBoss JIRA] (JGRP-2263) JGRP000225: failed unmarshalling buffer into return value
by Bela Ban (JIRA)
[ https://issues.jboss.org/browse/JGRP-2263?page=com.atlassian.jira.plugin.... ]
Bela Ban updated JGRP-2263:
---------------------------
Steps to Reproduce:
{code:java}
public class SimpleChat {
JChannel channel;
RpcDispatcher dispatcher;
private static final RequestOptions IMPORTANT = new RequestOptions(ResponseMode.GET_ALL, TimeUnit.SECONDS.toMillis(60)).setFlags(Message.Flag.DONT_BUNDLE);
private void start() throws Exception {
channel = new JChannel();
dispatcher = new RpcDispatcher(channel, new Test() {
});
channel.connect("ChatCluster");
channel.getState(null, 10000);
Method test = Test.class.getMethod("test");
Object o = dispatcher.callRemoteMethods(null, new MethodCall(test), IMPORTANT);
System.out.println(o);
channel.close();
}
public static void main(String[] args) throws Exception {
new SimpleChat().start();
}
public static class Test {
public Object test() {
return new EError(EError.EErrorKind.WRONG_PARAMS);
}
}
public static class EError extends Error {
private static final long serialVersionUID = 1L;
enum EErrorKind {
WRONG_PARAMS,
}
final EErrorKind code;
public EError(EError.EErrorKind code) {
this.code = code;
}
}
}
{code}
was:
public class SimpleChat {
JChannel channel;
RpcDispatcher dispatcher;
private static final RequestOptions IMPORTANT = new RequestOptions(ResponseMode.GET_ALL, TimeUnit.SECONDS.toMillis(60)).setFlags(Message.Flag.DONT_BUNDLE);
private void start() throws Exception {
channel = new JChannel();
dispatcher = new RpcDispatcher(channel, new Test() {
});
channel.connect("ChatCluster");
channel.getState(null, 10000);
Method test = Test.class.getMethod("test");
Object o = dispatcher.callRemoteMethods(null, new MethodCall(test), IMPORTANT);
System.out.println(o);
channel.close();
}
public static void main(String[] args) throws Exception {
new SimpleChat().start();
}
public static class Test {
public Object test() {
return new EError(EError.EErrorKind.WRONG_PARAMS);
}
}
public static class EError extends Error {
private static final long serialVersionUID = 1L;
enum EErrorKind {
WRONG_PARAMS,
}
final EErrorKind code;
public EError(EError.EErrorKind code) {
this.code = code;
}
}
}
> JGRP000225: failed unmarshalling buffer into return value
> ---------------------------------------------------------
>
> Key: JGRP-2263
> URL: https://issues.jboss.org/browse/JGRP-2263
> Project: JGroups
> Issue Type: Bug
> Affects Versions: 4.0.11
> Environment: jdk1.8.0_66.jdk
> osx 10.10 & ubuntu 17.10
> Reporter: rama rama
> Assignee: Bela Ban
> Fix For: 4.0.12
>
> Attachments: SimpleChat.java
>
>
> trying to send a class that previous work with 3.x return
> "failed unmarshalling buffer into return value"
> jgroups instance it's configured with the default settings
> i create a test case to reproduce it, executing this class on my 2 boxes return
> ----
> GRAVE: JGRP000225: failed unmarshalling buffer into return value
> java.lang.InstantiationException: com.eg.util.comm.SimpleChat$EError
> at java.lang.Class.newInstance(Class.java:427)
> at org.jgroups.util.Util.readException(Util.java:899)
> at org.jgroups.util.Util.exceptionFromStream(Util.java:843)
> at org.jgroups.util.Util.exceptionFromStream(Util.java:831)
> at org.jgroups.util.Util.objectFromStream(Util.java:782)
> at org.jgroups.util.Util.objectFromStream(Util.java:742)
> at org.jgroups.blocks.RequestCorrelator.replyFromBuffer(RequestCorrelator.java:463)
> at org.jgroups.blocks.RequestCorrelator.handleResponse(RequestCorrelator.java:408)
> at org.jgroups.blocks.RequestCorrelator.dispatch(RequestCorrelator.java:363)
> at org.jgroups.blocks.RequestCorrelator.receiveMessageBatch(RequestCorrelator.java:326)
> at org.jgroups.blocks.MessageDispatcher$ProtocolAdapter.up(MessageDispatcher.java:589)
> at org.jgroups.JChannel.up(JChannel.java:837)
> at org.jgroups.stack.ProtocolStack.up(ProtocolStack.java:896)
> at org.jgroups.stack.Protocol.up(Protocol.java:372)
> at org.jgroups.protocols.RSVP.up(RSVP.java:233)
> at org.jgroups.protocols.FRAG2.up(FRAG2.java:196)
> at org.jgroups.protocols.FlowControl.up(FlowControl.java:416)
> at org.jgroups.protocols.FlowControl.up(FlowControl.java:416)
> at org.jgroups.stack.Protocol.up(Protocol.java:372)
> at org.jgroups.protocols.pbcast.STABLE.up(STABLE.java:293)
> at org.jgroups.protocols.UNICAST3.deliverBatch(UNICAST3.java:1024)
> at org.jgroups.protocols.UNICAST3.removeAndDeliver(UNICAST3.java:833)
> at org.jgroups.protocols.UNICAST3.handleBatchFromSelf(UNICAST3.java:520)
> at org.jgroups.protocols.UNICAST3.up(UNICAST3.java:435)
> at org.jgroups.protocols.pbcast.NAKACK2.up(NAKACK2.java:697)
> at org.jgroups.protocols.BARRIER.up(BARRIER.java:195)
> at org.jgroups.stack.Protocol.up(Protocol.java:372)
> at org.jgroups.protocols.FD_ALL.up(FD_ALL.java:212)
> at org.jgroups.stack.Protocol.up(Protocol.java:372)
> at org.jgroups.stack.Protocol.up(Protocol.java:372)
> at org.jgroups.stack.Protocol.up(Protocol.java:372)
> at org.jgroups.protocols.TP.passBatchUp(TP.java:1274)
> at org.jgroups.util.MaxOneThreadPerSender$BatchHandlerLoop.passBatchUp(MaxOneThreadPerSender.java:284)
> at org.jgroups.util.SubmitToThreadPool$BatchHandler.run(SubmitToThreadPool.java:136)
> at org.jgroups.util.MaxOneThreadPerSender$BatchHandlerLoop.run(MaxOneThreadPerSender.java:273)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> at java.lang.Thread.run(Thread.java:745)
> Caused by: java.lang.NoSuchMethodException: com.eg.util.comm.SimpleChat$EError.<init>()
> at java.lang.Class.getConstructor0(Class.java:3082)
> at java.lang.Class.newInstance(Class.java:412)
> ... 37 more
> -----
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
8 years
[JBoss JIRA] (JGRP-2263) JGRP000225: failed unmarshalling buffer into return value
by Bela Ban (JIRA)
[ https://issues.jboss.org/browse/JGRP-2263?page=com.atlassian.jira.plugin.... ]
Bela Ban updated JGRP-2263:
---------------------------
Summary: JGRP000225: failed unmarshalling buffer into return value (was: GRAVE: JGRP000225: failed unmarshalling buffer into return value)
> JGRP000225: failed unmarshalling buffer into return value
> ---------------------------------------------------------
>
> Key: JGRP-2263
> URL: https://issues.jboss.org/browse/JGRP-2263
> Project: JGroups
> Issue Type: Bug
> Affects Versions: 4.0.11
> Environment: jdk1.8.0_66.jdk
> osx 10.10 & ubuntu 17.10
> Reporter: rama rama
> Assignee: Bela Ban
> Fix For: 4.0.12
>
> Attachments: SimpleChat.java
>
>
> trying to send a class that previous work with 3.x return
> "failed unmarshalling buffer into return value"
> jgroups instance it's configured with the default settings
> i create a test case to reproduce it, executing this class on my 2 boxes return
> ----
> GRAVE: JGRP000225: failed unmarshalling buffer into return value
> java.lang.InstantiationException: com.eg.util.comm.SimpleChat$EError
> at java.lang.Class.newInstance(Class.java:427)
> at org.jgroups.util.Util.readException(Util.java:899)
> at org.jgroups.util.Util.exceptionFromStream(Util.java:843)
> at org.jgroups.util.Util.exceptionFromStream(Util.java:831)
> at org.jgroups.util.Util.objectFromStream(Util.java:782)
> at org.jgroups.util.Util.objectFromStream(Util.java:742)
> at org.jgroups.blocks.RequestCorrelator.replyFromBuffer(RequestCorrelator.java:463)
> at org.jgroups.blocks.RequestCorrelator.handleResponse(RequestCorrelator.java:408)
> at org.jgroups.blocks.RequestCorrelator.dispatch(RequestCorrelator.java:363)
> at org.jgroups.blocks.RequestCorrelator.receiveMessageBatch(RequestCorrelator.java:326)
> at org.jgroups.blocks.MessageDispatcher$ProtocolAdapter.up(MessageDispatcher.java:589)
> at org.jgroups.JChannel.up(JChannel.java:837)
> at org.jgroups.stack.ProtocolStack.up(ProtocolStack.java:896)
> at org.jgroups.stack.Protocol.up(Protocol.java:372)
> at org.jgroups.protocols.RSVP.up(RSVP.java:233)
> at org.jgroups.protocols.FRAG2.up(FRAG2.java:196)
> at org.jgroups.protocols.FlowControl.up(FlowControl.java:416)
> at org.jgroups.protocols.FlowControl.up(FlowControl.java:416)
> at org.jgroups.stack.Protocol.up(Protocol.java:372)
> at org.jgroups.protocols.pbcast.STABLE.up(STABLE.java:293)
> at org.jgroups.protocols.UNICAST3.deliverBatch(UNICAST3.java:1024)
> at org.jgroups.protocols.UNICAST3.removeAndDeliver(UNICAST3.java:833)
> at org.jgroups.protocols.UNICAST3.handleBatchFromSelf(UNICAST3.java:520)
> at org.jgroups.protocols.UNICAST3.up(UNICAST3.java:435)
> at org.jgroups.protocols.pbcast.NAKACK2.up(NAKACK2.java:697)
> at org.jgroups.protocols.BARRIER.up(BARRIER.java:195)
> at org.jgroups.stack.Protocol.up(Protocol.java:372)
> at org.jgroups.protocols.FD_ALL.up(FD_ALL.java:212)
> at org.jgroups.stack.Protocol.up(Protocol.java:372)
> at org.jgroups.stack.Protocol.up(Protocol.java:372)
> at org.jgroups.stack.Protocol.up(Protocol.java:372)
> at org.jgroups.protocols.TP.passBatchUp(TP.java:1274)
> at org.jgroups.util.MaxOneThreadPerSender$BatchHandlerLoop.passBatchUp(MaxOneThreadPerSender.java:284)
> at org.jgroups.util.SubmitToThreadPool$BatchHandler.run(SubmitToThreadPool.java:136)
> at org.jgroups.util.MaxOneThreadPerSender$BatchHandlerLoop.run(MaxOneThreadPerSender.java:273)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> at java.lang.Thread.run(Thread.java:745)
> Caused by: java.lang.NoSuchMethodException: com.eg.util.comm.SimpleChat$EError.<init>()
> at java.lang.Class.getConstructor0(Class.java:3082)
> at java.lang.Class.newInstance(Class.java:412)
> ... 37 more
> -----
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
8 years
[JBoss JIRA] (JGRP-2263) GRAVE: JGRP000225: failed unmarshalling buffer into return value
by Bela Ban (JIRA)
[ https://issues.jboss.org/browse/JGRP-2263?page=com.atlassian.jira.plugin.... ]
Bela Ban updated JGRP-2263:
---------------------------
Fix Version/s: 4.0.12
Steps to Reproduce:
public class SimpleChat {
JChannel channel;
RpcDispatcher dispatcher;
private static final RequestOptions IMPORTANT = new RequestOptions(ResponseMode.GET_ALL, TimeUnit.SECONDS.toMillis(60)).setFlags(Message.Flag.DONT_BUNDLE);
private void start() throws Exception {
channel = new JChannel();
dispatcher = new RpcDispatcher(channel, new Test() {
});
channel.connect("ChatCluster");
channel.getState(null, 10000);
Method test = Test.class.getMethod("test");
Object o = dispatcher.callRemoteMethods(null, new MethodCall(test), IMPORTANT);
System.out.println(o);
channel.close();
}
public static void main(String[] args) throws Exception {
new SimpleChat().start();
}
public static class Test {
public Object test() {
return new EError(EError.EErrorKind.WRONG_PARAMS);
}
}
public static class EError extends Error {
private static final long serialVersionUID = 1L;
enum EErrorKind {
WRONG_PARAMS,
}
final EErrorKind code;
public EError(EError.EErrorKind code) {
this.code = code;
}
}
}
was:
public class SimpleChat {
JChannel channel;
RpcDispatcher dispatcher;
private static final RequestOptions IMPORTANT = new RequestOptions(ResponseMode.GET_ALL, TimeUnit.SECONDS.toMillis(60)).setFlags(Message.Flag.DONT_BUNDLE);
private void start() throws Exception {
channel = new JChannel();
dispatcher = new RpcDispatcher(channel, new Test() {
});
channel.connect("ChatCluster");
channel.getState(null, 10000);
Method test = Test.class.getMethod("test");
Object o = dispatcher.callRemoteMethods(null, new MethodCall(test), IMPORTANT);
System.out.println(o);
channel.close();
}
public static void main(String[] args) throws Exception {
new SimpleChat().start();
}
public static class Test {
public Object test() {
return new EError(EError.EErrorKind.WRONG_PARAMS);
}
}
public static class EError extends Error {
private static final long serialVersionUID = 1L;
enum EErrorKind {
WRONG_PARAMS,
}
final EErrorKind code;
public EError(EError.EErrorKind code) {
this.code = code;
}
}
}
OK, so the problem is that exceptions were marshalled/unmarshalled as a special case, and the marshalling included only the stack trace and error message.
This was done to improve performance of RPCs. However, as exceptions are not thrown frequently, I'll remove the TYPE_EXCEPTION type again and marshall exceptions as Serializable.
> GRAVE: JGRP000225: failed unmarshalling buffer into return value
> ----------------------------------------------------------------
>
> Key: JGRP-2263
> URL: https://issues.jboss.org/browse/JGRP-2263
> Project: JGroups
> Issue Type: Bug
> Affects Versions: 4.0.11
> Environment: jdk1.8.0_66.jdk
> osx 10.10 & ubuntu 17.10
> Reporter: rama rama
> Assignee: Bela Ban
> Fix For: 4.0.12
>
> Attachments: SimpleChat.java
>
>
> trying to send a class that previous work with 3.x return
> "failed unmarshalling buffer into return value"
> jgroups instance it's configured with the default settings
> i create a test case to reproduce it, executing this class on my 2 boxes return
> ----
> GRAVE: JGRP000225: failed unmarshalling buffer into return value
> java.lang.InstantiationException: com.eg.util.comm.SimpleChat$EError
> at java.lang.Class.newInstance(Class.java:427)
> at org.jgroups.util.Util.readException(Util.java:899)
> at org.jgroups.util.Util.exceptionFromStream(Util.java:843)
> at org.jgroups.util.Util.exceptionFromStream(Util.java:831)
> at org.jgroups.util.Util.objectFromStream(Util.java:782)
> at org.jgroups.util.Util.objectFromStream(Util.java:742)
> at org.jgroups.blocks.RequestCorrelator.replyFromBuffer(RequestCorrelator.java:463)
> at org.jgroups.blocks.RequestCorrelator.handleResponse(RequestCorrelator.java:408)
> at org.jgroups.blocks.RequestCorrelator.dispatch(RequestCorrelator.java:363)
> at org.jgroups.blocks.RequestCorrelator.receiveMessageBatch(RequestCorrelator.java:326)
> at org.jgroups.blocks.MessageDispatcher$ProtocolAdapter.up(MessageDispatcher.java:589)
> at org.jgroups.JChannel.up(JChannel.java:837)
> at org.jgroups.stack.ProtocolStack.up(ProtocolStack.java:896)
> at org.jgroups.stack.Protocol.up(Protocol.java:372)
> at org.jgroups.protocols.RSVP.up(RSVP.java:233)
> at org.jgroups.protocols.FRAG2.up(FRAG2.java:196)
> at org.jgroups.protocols.FlowControl.up(FlowControl.java:416)
> at org.jgroups.protocols.FlowControl.up(FlowControl.java:416)
> at org.jgroups.stack.Protocol.up(Protocol.java:372)
> at org.jgroups.protocols.pbcast.STABLE.up(STABLE.java:293)
> at org.jgroups.protocols.UNICAST3.deliverBatch(UNICAST3.java:1024)
> at org.jgroups.protocols.UNICAST3.removeAndDeliver(UNICAST3.java:833)
> at org.jgroups.protocols.UNICAST3.handleBatchFromSelf(UNICAST3.java:520)
> at org.jgroups.protocols.UNICAST3.up(UNICAST3.java:435)
> at org.jgroups.protocols.pbcast.NAKACK2.up(NAKACK2.java:697)
> at org.jgroups.protocols.BARRIER.up(BARRIER.java:195)
> at org.jgroups.stack.Protocol.up(Protocol.java:372)
> at org.jgroups.protocols.FD_ALL.up(FD_ALL.java:212)
> at org.jgroups.stack.Protocol.up(Protocol.java:372)
> at org.jgroups.stack.Protocol.up(Protocol.java:372)
> at org.jgroups.stack.Protocol.up(Protocol.java:372)
> at org.jgroups.protocols.TP.passBatchUp(TP.java:1274)
> at org.jgroups.util.MaxOneThreadPerSender$BatchHandlerLoop.passBatchUp(MaxOneThreadPerSender.java:284)
> at org.jgroups.util.SubmitToThreadPool$BatchHandler.run(SubmitToThreadPool.java:136)
> at org.jgroups.util.MaxOneThreadPerSender$BatchHandlerLoop.run(MaxOneThreadPerSender.java:273)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> at java.lang.Thread.run(Thread.java:745)
> Caused by: java.lang.NoSuchMethodException: com.eg.util.comm.SimpleChat$EError.<init>()
> at java.lang.Class.getConstructor0(Class.java:3082)
> at java.lang.Class.newInstance(Class.java:412)
> ... 37 more
> -----
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
8 years
[JBoss JIRA] (DROOLS-2421) Unexpected response from rule engine for windowing rules
by Bishnu Shankar Pandey (JIRA)
[ https://issues.jboss.org/browse/DROOLS-2421?page=com.atlassian.jira.plugi... ]
Bishnu Shankar Pandey closed DROOLS-2421.
-----------------------------------------
Resolution: Won't Fix
> Unexpected response from rule engine for windowing rules
> --------------------------------------------------------
>
> Key: DROOLS-2421
> URL: https://issues.jboss.org/browse/DROOLS-2421
> Project: Drools
> Issue Type: Bug
> Components: core engine
> Affects Versions: 6.5.0.Final
> Reporter: Bishnu Shankar Pandey
> Assignee: Mario Fusco
> Priority: Critical
> Labels: Critical
> Attachments: DroolsTest.zip
>
>
> Here the sample code of my window rule :
> rule "Sliding window test1"
> agenda-group "g0"
> when
> exists Fact( (facts["parameter2"] ) != null && facts["source"] == "A0") && $number: Number() from accumulate(Fact(facts["parameter2"] != null && $t : Double.valueOf(facts["parameter2"]) && facts["source"] == "A0") over window:time(2m) , sum($t))
> then
> globalList.add("2 Minute Sum of parameter2 of Source A0 is " + $number );
> end
> rule "Sliding window test2"
> agenda-group "g0"
> when
> exists Fact( (facts["parameter2"] ) != null && facts["source"] == "A1") && $number: Number() from accumulate(Fact(facts["parameter2"] != null && $t : Double.valueOf(facts["parameter2"]) && facts["source"] == "A1") over window:time(2m) , sum($t))
> then
> globalList.add("2 Minute Sum of parameter2 of Source A1 is " + $number );
> end
> I am sending request from 2 different sources. I am getting response as 0.0 after some time. I check the values in the working memory by using collect as List for the parameter values. I have found that the previous values got deleted when the response is 0.0. I need immediate help.
> Some important info:
> Fact is the class Object and it has a Hashmap(facts) as class variable. The factmap contains the variable name as key and its value as variable value.
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
8 years
[JBoss JIRA] (WFLY-10109) [Artemis 2.x upgrade] MDB connected to remote server does not get activated when using discovery group with JGroups
by Erich Duda (JIRA)
[ https://issues.jboss.org/browse/WFLY-10109?page=com.atlassian.jira.plugin... ]
Erich Duda commented on WFLY-10109:
-----------------------------------
[~jmesnil] I think this is not environment issue. The servers communicate through localhost.
I tried to run the test with thread which prints regularly thread dumps of all servers to files. However with this thread the test passed 50 times in row. I think the issue is caused by race condition and making of thread dumps changed slightly the execution so the issue hasn't appeared.
I think the best way how to investigate it is by adding more logs to the code. You can clone my job and use it for this purpose. It accepts parameters ARTEMIS_REPO and ARTEMIS_VERSION. When they are filled, custom version of Artemis is built and used with Wildfly build so you can easily add more logs to Artemis code.
> [Artemis 2.x upgrade] MDB connected to remote server does not get activated when using discovery group with JGroups
> --------------------------------------------------------------------------------------------------------------------
>
> Key: WFLY-10109
> URL: https://issues.jboss.org/browse/WFLY-10109
> Project: WildFly
> Issue Type: Bug
> Components: JMS
> Reporter: Miroslav Novak
> Assignee: Jeff Mesnil
> Priority: Blocker
> Labels: feature-branch-blocker
> Attachments: log
>
>
> Sometimes happens that MDB does not start to consume messages from remote server. There are not warning or error messages in log.
> Test Scenario:
> * Start server with deployed InQueue and OutQueue
> * Start 2nd server with configured pooled-connection-factory to connect to 1st server
> * Deploy MDB to 2nd server - mdb is consuming messages from InQueue and sending to OutQueue
> * Start sending messages to InQueue to 1st server
> * Let MDB processing messages from InQueue
> * Start consuming messages from OutQueue from 1st server
> Pass Criteria: There is the same number of sent and received messages
> Actual Result: Sometimes happens that Mdb does not start to consume messages.
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
8 years