java.lang.ClassCastException io.bigio.benchmark.throughput.ThroughputMessage cannot be cast to io.bigio.core.codec.BigIOMessage

[sarfarazengglb]

Hi Team,

This error is found in every example and test class.Can you advice how to fix the Issue.

20:51:20.156 [Thread-0] ERROR io.bigio.core.codec.GenericCodec - Exception serializing.
java.lang.ClassCastException: io.bigio.benchmark.throughput.ThroughputMessage cannot be cast to io.bigio.core.codec.BigIOMessage
at io.bigio.core.codec.GenericCodec.encode(GenericCodec.java:94) ~[classes/:na]
at io.bigio.core.ClusterService.sendMessage(ClusterService.java:263) [classes/:na]
at io.bigio.core.ClusterService.sendMessage(ClusterService.java:282) [classes/:na]
at io.bigio.BigIO.send(BigIO.java:169) [classes/:na]
at io.bigio.BigIO.send(BigIO.java:142) [classes/:na]

[andy-trimble]

Hello,

There are two reasons why this exception might be thrown.

1. The @message annotation is missing from the message being sent
2. The agent has not been attached to the runtime

In order to attach the agent to the runtime, ensure that the following parameter is being used when starting a BigIO enabled program:

-javaagent:<path to bigio-agent jar file>

[andy-trimble]

I updated the main wiki page to include documentation to this effect. Please verify that this corrects the problem and I will close the issue.

[sarfarazengglb]

As adviced i am using same code.Used latest Maven and agent jar.I am working with two different process.In one process i have made producer(with listener and sender) and in other consumer(Only listener).

If i run the producer directly it is working fine it is injecting properly.But if i start Producer Process and consumer Process than it is processing Producer's message listener and when it is delivering the message of separate Consumer listener it is throwing nullpointer.I did step by step debug a debug trace i found this line is giving issue.

ret = (byte[])((BigIOMessage)message).bigioencode();

Strangle both uses same code.First cycle is working as accepted but second instance listner making issue
public static byte[] encode(Object message) throws IOException {

    if(message.getClass().getAnnotation(io.bigio.Message.class) != null) {
        try {
            byte[] ret;
            ret = (byte[])((BigIOMessage)message).bigioencode();
            return ret;
        } catch (Exception ex) {
            LOG.error("Exception serializing.", ex);
        }
    }

    return null;
}

I am using Netbeans to run the process.Both use same code same JDK 1.8.

[andy-trimble]

How are you executing the processes? Are you using NetBeans, or do you have a script to handle that? Can you provide the commands you're executing for both the consumer and the producer?

[sarfarazengglb]

I am using Netbeans to run the process.
My OS is windows 10 and Acer Device
Tried with both github code and Maven dependency from rep.
JDK is 1.8
I also implemented bigiodecode and bigioencode and changed the line to below it worked with two process but that is not good approach.Messaging need to use default feature as it is designed and encrypt message automatically.
As i am using IDE it produce the bootup by itself.

// ret = (byte[])((BigIOMessage)message).bigioencode();
ret = (byte[]) message.getClass().getMethod("bigioencode").invoke(message);

Producer
cd C:\Personal\My Project\Sample\BigIOApp; "JAVA_HOME=C:\Program Files\Java\jdk1.8.0_45" cmd /c """C:\Program Files\NetBeans 8.0.2\java\maven\bin\mvn.bat" -Dexec.args="-classpath %classpath io.bigio.examples.helloworld.Producer" -Dexec.executable="C:\Program Files\Java\jdk1.8.0_45\bin\java.exe" -Dexec.classpathScope=runtime -Dmaven.ext.class.path="C:\Program Files\NetBeans 8.0.2\java\maven-nblib\netbeans-eventspy.jar;C:\Program Files\NetBeans 8.0.2\java\maven-nblib\netbeans-cos.jar" -Dfile.encoding=UTF-8 org.codehaus.mojo:exec-maven-plugin:1.2.1:exec""

Consumer
cd C:\Personal\My Project\Sample\BigIOApp; "JAVA_HOME=C:\Program Files\Java\jdk1.8.0_45" cmd /c """C:\Program Files\NetBeans 8.0.2\java\maven\bin\mvn.bat" -Dexec.args="-classpath %classpath io.bigio.examples.helloworld.Consumer" -Dexec.executable="C:\Program Files\Java\jdk1.8.0_45\bin\java.exe" -Dexec.classpathScope=runtime -Dmaven.ext.class.path="C:\Program Files\NetBeans 8.0.2\java\maven-nblib\netbeans-eventspy.jar;C:\Program Files\NetBeans 8.0.2\java\maven-nblib\netbeans-cos.jar" -Dfile.encoding=UTF-8 org.codehaus.mojo:exec-maven-plugin:1.2.1:exec""

[andy-trimble]

It is not necessary (and will cause errors) to implement bigioencode and bigiodecode. Rather, add an execution flag "-javaagent=C:/some/directory/bigio-agent-1.2.jar". I'm unsure how to do this in NetBeans, but you should be able to configure your project to include this runtime flag.

Take a look here to read about how Java Agents work.

[sarfarazengglb]

It is working.Thank you Andy.

java -javaagent:bin/bigio-agent-1.2.jar -Xmx2048m -Xms2048m -cp "bin/.jar;config;lib/;components/"

Modified the assemble file.