[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)
6 years, 6 months
[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)
6 years, 6 months
[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)
6 years, 6 months
[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)
6 years, 6 months
[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)
6 years, 6 months