Hi,
I'm trying to run a bundle in Karaf that has multiple nodes in a Cluster.
The bundles are split, the core bundle provides ActorSystem via the
TestServiceInterface interface. I'm using DS to initialize the Components.
The problem I'm facing is that my JVM is exiting.
The error I'm getting is NoSuchMethodError whereas in my karaf I have all
the appropriate jars loaded.
My karaf instance -
ID State Blueprint Level Name
[ 54] [Active ] [ ] [ 80] camel-core (2.13.0)
[ 56] [Active ] [Created ] [ 80] camel-blueprint (2.13.0)
[ 71] [Active ] [Created ] [ 80] DemoOSGI1 (1.0)
[ 73] [Active ] [ ] [ 80] Apache Felix Declarative
Services (1.8.2)
[ 78] [Active ] [ ] [ 80]
file:///home/Desktop/libs/javax.transaction.jar
[ 80] [Active ] [ ] [ 80] ehcache (2.8.0)
[ 84] [Active ] [ ] [ 80] Apache Aries Transaction
Manager (1.1.0)
[ 97] [Active ] [ ] [ 80] Scala Standard Library
(2.10.0.v20121205-112020-VFINAL-18481cef9b)
[ 99] [Active ] [ ] [ 80] com.typesafe.config (1.2.1)
[ 100] [Active ] [ ] [ 80] com.typesafe.akka.osgi (2.3.4)
[ 103] [Active ] [ ] [ 80] com.typesafe.akka.camel (2.3.4)
[ 106] [Active ] [ ] [ 80] com.typesafe.akka.cluster
(2.3.4)
[ 107] [Active ] [ ] [ 80] Protocol Buffer Java API (2.5.0)
[ 108] [Active ] [ ] [ 80] com.typesafe.akka.remote (2.3.4)
[ 109] [Active ] [ ] [ 80] The Netty Project (3.8.0.Final)
[ 112] [Active ] [ ] [ 80]
wrap_file____home_exyybcc_Downloads_jars_uncommons-maths-1.2.2.jar (0)
[ 118] [Active ] [ ] [ 80] com.typesafe.akka.slf4j (2.3.4)
[ 126] [Active ] [ ] [ 80]
wrap_file____home_exyybcc_Downloads_trace-akka-2.1.4-1.2.0.jar (0)
[ 136] [Active ] [ ] [ 80] com.typesafe.akka.actor (2.3.4)
[ 145] [Active ] [ ] [ 80] pmedcorebundle (1.0)
[ 146] [Active ] [ ] [ 80] FileConsumerBundle (1.0)
I'm not clear where to start. Please guide
I have deployed all the necessary jars - akka-cluster, akka-osgi,
akka-actor, protobuf, uncommon math, slf4j, akk-slf4j. version -2.3.4
*StackTrace*
karaf@root> install -s
file:///home/workspace/FileTransformerBundle/build/libs/FileTransformerBundle-1.0.jar
PmedEngineFileTransformerNode Calling bindInterface
FileTransformerNode activate
com.serviceimpl.TestServiceInterfaceImpl@1c8cf739
FileRecordRoutingActor and FileRouteTransformerActor actors built
Uncaught error from thread [ActorSystem-12001-akka.actor.default-dispatcher-
16] shutting down JVM since 'akka.jvm-exit-on-fatal-error' is enabled for
ActorSystem[ActorSystem-12001]
java.lang.NoSuchMethodError: akka.cluster.Cluster.subscribe(Lakka/actor/
ActorRef;Ljava/lang/Class;)V
at com.foundation.engine.actors.FileRouteTransformerActor.preStart(
FileRouteTransformerActor.java:40)
at akka.actor.Actor$class.aroundPreStart(Actor.scala:470)
at akka.actor.UntypedActor.aroundPreStart(UntypedActor.scala:97)
at akka.actor.ActorCell.create(ActorCell.scala:580)
at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:456)
at akka.actor.ActorCell.systemInvoke(ActorCell.scala:478)
at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:263)
at akka.dispatch.Mailbox.run(Mailbox.scala:219)
at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(
AbstractDispatcher.scala:393)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:262)
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool
.java:975)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:
1478)
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(
ForkJoinWorkerThread.java:104)
TopupRecordConsumerActor built
Bundle ID: 147
my application.conf is as below -
akka {
event-handlers = ["akka.event.slf4j.Slf4jEventHandler"]
loggers = ["akka.event.slf4j.Slf4jLogger"]
loglevel = "DEBUG"
actor {
provider = "akka.cluster.ClusterActorRefProvider"
}
remote {
log-received-messages = off
log-sent-messages = off
log-remote-lifecycle-events = off
untrusted-mode=on
netty.tcp {
hostname = "127.0.0.1"
port = 0
}
}
cluster {
seed-nodes = [
"akka.tcp://[email protected]:2551",
"akka.tcp://[email protected]:2552"]
auto-down-unreachable-after = 10s
}
camel {
# Whether JMX should be enabled or disabled for the Camel Context
jmx = off
# enable/disable streaming cache on the Camel Context
streamingCache = on
consumer {
# Configured setting which determines whether one-way communications
# between an endpoint and this consumer actor
# should be auto-acknowledged or application-acknowledged.
# This flag has only effect when exchange is in-only.
auto-ack = on
# When endpoint is out-capable (can produce responses) reply-timeout is
the
# maximum time the endpoint can take to send the response before the
message
# exchange fails. This setting is used for out-capable, in-only,
# manually acknowledged communication.
reply-timeout = 1m
# The duration of time to await activation of an endpoint.
activation-timeout = 10s
}
}
}
Please suggest as to where should I start looking into.
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
