Calling DefaultCacheManager.start() does not start DefaultCacheManager
by Olaf Bergner
One minor glitch I stumbled upon while implementing Spring Infinispan:
final DefaultCacheManager cm = new DefaultCacheManager(false);
cm.start();
assertEquals(ComponentStatus.RUNNING, cm.getStatus());
fails with
java.lang.AssertionError: expected:<RUNNING> but was:<INSTANTIATED>
since you need to call getCache() or getCache(name) before
DefaultCacheManager is actually started.
Obviously not a big deal, but it arguably doesn't follow the principle
of least surprise. Is it worth doing something about it?
Cheers,
Olaf
15 years
Help me to overcome marshall/unmarshall exception
by Pavana Kumari
Hi
Am getting below exception please help me to overcome the below exception
org.infinispan.CacheException: Problems invoking command.
at org.infinispan.remoting.transport.jgroups.CommandAwareRpcDispatcher.handle(CommandAwareRpcDispatcher.java:158)
at org.jgroups.blocks.RequestCorrelator.handleRequest(RequestCorrelator.java:577)
at org.jgroups.blocks.RequestCorrelator.receiveMessage(RequestCorrelator.java:488)
at org.jgroups.blocks.RequestCorrelator.receive(RequestCorrelator.java:364)
at org.jgroups.blocks.MessageDispatcher$ProtocolAdapter.up(MessageDispatcher.java:770)
at org.jgroups.JChannel.up(JChannel.java:1466)
at org.jgroups.stack.ProtocolStack.up(ProtocolStack.java:953)
at org.jgroups.protocols.pbcast.FLUSH.up(FLUSH.java:477)
at org.jgroups.protocols.pbcast.STREAMING_STATE_TRANSFER.up(STREAMING_STATE_TRANSFER.java:262)
at org.jgroups.protocols.FRAG2.up(FRAG2.java:189)
at org.jgroups.protocols.FlowControl.up(FlowControl.java:418)
at org.jgroups.protocols.FlowControl.up(FlowControl.java:418)
at org.jgroups.protocols.pbcast.GMS.up(GMS.java:887)
at org.jgroups.protocols.pbcast.STABLE.up(STABLE.java:233)
at org.jgroups.protocols.UNICAST.up(UNICAST.java:309)
at org.jgroups.protocols.pbcast.NAKACK.handleMessage(NAKACK.java:841)
at org.jgroups.protocols.pbcast.NAKACK.up(NAKACK.java:704)
at org.jgroups.protocols.BARRIER.up(BARRIER.java:119)
at org.jgroups.protocols.FD_ALL.up(FD_ALL.java:168)
at org.jgroups.protocols.FD_SOCK.up(FD_SOCK.java:274)
at org.jgroups.protocols.MERGE2.up(MERGE2.java:209)
at org.jgroups.protocols.Discovery.up(Discovery.java:291)
at org.jgroups.protocols.PING.up(PING.java:66)
at org.jgroups.protocols.TP.passMessageUp(TP.java:1092)
at org.jgroups.protocols.TP$IncomingPacket.handleMyMessage(TP.java:1632)
at org.jgroups.protocols.TP$IncomingPacket.run(TP.java:1614)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:619)
Caused by: java.lang.ClassNotFoundException: com.angel.Infinispan.poc.CallCenter
at java.net.URLClassLoader$1.run(URLClassLoader.java:202)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:190)
at java.lang.ClassLoader.loadClass(ClassLoader.java:307)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301)
at java.lang.ClassLoader.loadClass(ClassLoader.java:248)
at java.lang.Class.forName0(Native Method)
at java.lang.Class.forName(Class.java:247)
at org.jboss.marshalling.AbstractClassResolver.loadClass(AbstractClassResolver.java:135)
at org.jboss.marshalling.AbstractClassResolver.resolveClass(AbstractClassResolver.java:116)
at org.jboss.marshalling.river.RiverUnmarshaller.doResolveClass(RiverUnmarshaller.java:1148)
at org.jboss.marshalling.river.RiverUnmarshaller.doReadClassDescriptor(RiverUnmarshaller.java:862)
at org.jboss.marshalling.river.RiverUnmarshaller.doReadNewObject(RiverUnmarshaller.java:1183)
at org.jboss.marshalling.river.RiverUnmarshaller.doReadObject(RiverUnmarshaller.java:270)
at org.jboss.marshalling.river.RiverUnmarshaller.doReadObject(RiverUnmarshaller.java:207)
at org.jboss.marshalling.AbstractUnmarshaller.readObject(AbstractUnmarshaller.java:85)
at org.infinispan.marshall.exts.ReplicableCommandExternalizer.readObject(ReplicableCommandExternalizer.java:75)
at org.infinispan.marshall.jboss.ConstantObjectTable$ExternalizerAdapter.readObject(ConstantObjectTable.java:317)
at org.infinispan.marshall.jboss.ConstantObjectTable.readObject(ConstantObjectTable.java:304)
at org.jboss.marshalling.river.RiverUnmarshaller.doReadObject(RiverUnmarshaller.java:357)
at org.jboss.marshalling.river.RiverUnmarshaller.doReadObject(RiverUnmarshaller.java:207)
at org.jboss.marshalling.AbstractUnmarshaller.readObject(AbstractUnmarshaller.java:85)
at org.infinispan.marshall.exts.ReplicableCommandExternalizer.readObject(ReplicableCommandExternalizer.java:75)
at org.infinispan.marshall.jboss.ConstantObjectTable$ExternalizerAdapter.readObject(ConstantObjectTable.java:317)
at org.infinispan.marshall.jboss.ConstantObjectTable.readObject(ConstantObjectTable.java:304)
at org.jboss.marshalling.river.RiverUnmarshaller.doReadObject(RiverUnmarshaller.java:357)
at org.jboss.marshalling.river.RiverUnmarshaller.doReadObject(RiverUnmarshaller.java:207)
at org.jboss.marshalling.AbstractUnmarshaller.readObject(AbstractUnmarshaller.java:85)
at org.infinispan.marshall.jboss.GenericJBossMarshaller.objectFromObjectStream(GenericJBossMarshaller.java:172)
at org.infinispan.marshall.VersionAwareMarshaller.objectFromByteBuffer(VersionAwareMarshaller.java:115)
at org.infinispan.remoting.transport.jgroups.MarshallerAdapter.objectFromByteBuffer(MarshallerAdapter.java:26)
at org.infinispan.remoting.transport.jgroups.CommandAwareRpcDispatcher.handle(CommandAwareRpcDispatcher.java:151)
... 28 more
org.infinispan.CacheException: Problems invoking command.
at org.infinispan.remoting.transport.jgroups.CommandAwareRpcDispatcher.handle(CommandAwareRpcDispatcher.java:158)
at org.jgroups.blocks.RequestCorrelator.handleRequest(RequestCorrelator.java:577)
at org.jgroups.blocks.RequestCorrelator.receiveMessage(RequestCorrelator.java:488)
at org.jgroups.blocks.RequestCorrelator.receive(RequestCorrelator.java:364)
at org.jgroups.blocks.MessageDispatcher$ProtocolAdapter.up(MessageDispatcher.java:770)
at org.jgroups.JChannel.up(JChannel.java:1466)
at org.jgroups.stack.ProtocolStack.up(ProtocolStack.java:953)
at org.jgroups.protocols.pbcast.FLUSH.up(FLUSH.java:477)
at org.jgroups.protocols.pbcast.STREAMING_STATE_TRANSFER.up(STREAMING_STATE_TRANSFER.java:262)
at org.jgroups.protocols.FRAG2.up(FRAG2.java:189)
at org.jgroups.protocols.FlowControl.up(FlowControl.java:418)
at org.jgroups.protocols.FlowControl.up(FlowControl.java:418)
at org.jgroups.protocols.pbcast.GMS.up(GMS.java:887)
at org.jgroups.protocols.pbcast.STABLE.up(STABLE.java:233)
at org.jgroups.protocols.UNICAST.up(UNICAST.java:309)
at org.jgroups.protocols.pbcast.NAKACK.handleMessage(NAKACK.java:841)
at org.jgroups.protocols.pbcast.NAKACK.up(NAKACK.java:704)
at org.jgroups.protocols.BARRIER.up(BARRIER.java:119)
at org.jgroups.protocols.FD_ALL.up(FD_ALL.java:168)
at org.jgroups.protocols.FD_SOCK.up(FD_SOCK.java:274)
at org.jgroups.protocols.MERGE2.up(MERGE2.java:209)
at org.jgroups.protocols.Discovery.up(Discovery.java:291)
at org.jgroups.protocols.PING.up(PING.java:66)
at org.jgroups.protocols.TP.passMessageUp(TP.java:1092)
at org.jgroups.protocols.TP$IncomingPacket.handleMyMessage(TP.java:1632)
at org.jgroups.protocols.TP$IncomingPacket.run(TP.java:1614)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:619)
Caused by: java.lang.ClassNotFoundException: com.angel.Infinispan.poc.CallCenter
at java.net.URLClassLoader$1.run(URLClassLoader.java:202)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:190)
at java.lang.ClassLoader.loadClass(ClassLoader.java:307)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301)
at java.lang.ClassLoader.loadClass(ClassLoader.java:248)
at java.lang.Class.forName0(Native Method)
at java.lang.Class.forName(Class.java:247)
at org.jboss.marshalling.AbstractClassResolver.loadClass(AbstractClassResolver.java:135)
at org.jboss.marshalling.AbstractClassResolver.resolveClass(AbstractClassResolver.java:116)
at org.jboss.marshalling.river.RiverUnmarshaller.doResolveClass(RiverUnmarshaller.java:1148)
at org.jboss.marshalling.river.RiverUnmarshaller.doReadClassDescriptor(RiverUnmarshaller.java:862)
at org.jboss.marshalling.river.RiverUnmarshaller.doReadNewObject(RiverUnmarshaller.java:1183)
at org.jboss.marshalling.river.RiverUnmarshaller.doReadObject(RiverUnmarshaller.java:270)
at org.jboss.marshalling.river.RiverUnmarshaller.doReadObject(RiverUnmarshaller.java:207)
at org.jboss.marshalling.AbstractUnmarshaller.readObject(AbstractUnmarshaller.java:85)
at org.infinispan.marshall.exts.ReplicableCommandExternalizer.readObject(ReplicableCommandExternalizer.java:75)
at org.infinispan.marshall.jboss.ConstantObjectTable$ExternalizerAdapter.readObject(ConstantObjectTable.java:317)
at org.infinispan.marshall.jboss.ConstantObjectTable.readObject(ConstantObjectTable.java:304)
at org.jboss.marshalling.river.RiverUnmarshaller.doReadObject(RiverUnmarshaller.java:357)
at org.jboss.marshalling.river.RiverUnmarshaller.doReadObject(RiverUnmarshaller.java:207)
at org.jboss.marshalling.AbstractUnmarshaller.readObject(AbstractUnmarshaller.java:85)
at org.infinispan.marshall.exts.ReplicableCommandExternalizer.readObject(ReplicableCommandExternalizer.java:75)
at org.infinispan.marshall.jboss.ConstantObjectTable$ExternalizerAdapter.readObject(ConstantObjectTable.java:317)
at org.infinispan.marshall.jboss.ConstantObjectTable.readObject(ConstantObjectTable.java:304)
at org.jboss.marshalling.river.RiverUnmarshaller.doReadObject(RiverUnmarshaller.java:357)
at org.jboss.marshalling.river.RiverUnmarshaller.doReadObject(RiverUnmarshaller.java:207)
at org.jboss.marshalling.AbstractUnmarshaller.readObject(AbstractUnmarshaller.java:85)
at org.infinispan.marshall.jboss.GenericJBossMarshaller.objectFromObjectStream(GenericJBossMarshaller.java:172)
at org.infinispan.marshall.VersionAwareMarshaller.objectFromByteBuffer(VersionAwareMarshaller.java:115)
at org.infinispan.remoting.transport.jgroups.MarshallerAdapter.objectFromByteBuffer(MarshallerAdapter.java:26)
at org.infinispan.remoting.transport.jgroups.CommandAwareRpcDispatcher.handle(CommandAwareRpcDispatcher.java:151)
Regards
Pavana
DISCLAIMER: This email message and all attachments are confidential and may contain information that is privileged, confidential or exempt from disclosure under applicable law. If you are not the intended recipient, you are notified that any dissemination, distribution or copying of this email is strictly prohibited. If you have received this email in error, please notify us immediately by return email or to mailadmin(a)spanservices.com and destroy the original message. Opinions, conclusions and other information in this message that do not relate to the official business of SPAN, shall be understood to be neither given nor endorsed by SPAN.
15 years
Help me in Clustering custom objects in infinispan
by Pavana Kumari
Hi
I am trying to cluster objects in infinispan but its showing marshall/unmarshall exception. Please help me finding solution to the problem
Regards
Pavana
DISCLAIMER: This email message and all attachments are confidential and may contain information that is privileged, confidential or exempt from disclosure under applicable law. If you are not the intended recipient, you are notified that any dissemination, distribution or copying of this email is strictly prohibited. If you have received this email in error, please notify us immediately by return email or to mailadmin(a)spanservices.com and destroy the original message. Opinions, conclusions and other information in this message that do not relate to the official business of SPAN, shall be understood to be neither given nor endorsed by SPAN.
15 years
Annotations
by Manik Surtani
In some ways related to the @Marshallable annotation thread, but in many ways not, I was having a look at:
http://code.google.com/p/ehcache-spring-annotations/
I think we need to do something in this space, to make life easier for developers to consume distributed caches. As such, what I'm thinking of is:
* Spring annotations for Infinispan - Olaf, will we get this for free with your work on the Spring cache adapter for Infinispan? If so, we should talk about this (blog, wiki, etc)
* SEAM annotations. Pete did a POC some while back, maybe we need to formalise this?
Other thoughts?
Cheers
Manik
--
Manik Surtani
manik(a)jboss.org
twitter.com/maniksurtani
Lead, Infinispan
http://www.infinispan.org
15 years
What really is Infinispan
by Israel Lacerra
Guys,
Sorry. It's probably not a dev question...
I'm writing a paper for my graduation (about Infinispan) as I said before.
I'm having some doubts about what Infinispan really is. I watched some Manik
presentations on internet and read a little articles. I saw Manik saying
something like Infinispan be a in memory data base, and not just a
distributed cache. And I read (
http://java.dzone.com/articles/data-service-data-fabric) that Infinispan is
something like Voldermort or Dynamo. And in some other sites, like
http://nosql-database.org/, Infinispan is classified like a "Grid Database
solution" (like Oracle Coherence) and somehow different of Voldermort.
Reading Infinispan documentation and these and other articles, I not really
sure what differs Infinispan and Voldermort.
I'm not really sure if I made myself clear, but I'm having some problems
defining what is Infinispan (or what Infinispan wants to be in the end)
(comparing with these other products).
Anyway... any replies to this mail could help me!
thanks!
Israel
15 years
Fwd: [hibernate-dev] JIRA notifications
by Galder Zamarreño
This looks interesting?
Begin forwarded message:
> From: Gunnar Morling <gunnar.morling(a)googlemail.com>
> Date: March 19, 2011 3:30:17 PM GMT+01:00
> To: Hardy Ferentschik <hibernate(a)ferentschik.de>, Steve Ebersole <steve(a)hibernate.org>
> Cc: hibernate-dev(a)lists.jboss.org, Dan Allen <dan.j.allen(a)gmail.com>
> Subject: Re: [hibernate-dev] JIRA notifications
>
> Hi,
>
> while talking about JIRA configuration another thing came into my mind,
> which relates to the issue workflow.
>
> For Seam's JIRA Dan set up an enhanced workflow, which provides a closer
> integration with GitHub pull requests. For one there is a dedicated issue
> field "pull request", but also the issue lifecycle is linked to pull
> requests with a new issue state "pull request sent".
>
> IMO that's pretty useful as it improves visibility of the issue/pull request
> relationship and reduces chances, that pull requests get lost. More
> information can be found in this mail:
>
> http://seam-framework.2283336.n4.nabble.com/git-pull-request-JIRA-workflo...
>
> In case there should be interest in using that workflow for Hibernate's JIRA
> I think Dan would happily provide more information how this was set up.
>
> Gunnar
>
>
>
> More information
>
> 2011/3/19 Gunnar Morling <gunnar.morling(a)googlemail.com>
>
>> Right, for HV that notification scheme is used and I consider it useful,
>> too.
>>
>> Gunnar
>>
>>
>> 2011/3/19 Hardy Ferentschik <hibernate(a)ferentschik.de>
>>
>>> I think it makes sense for all projects. I think Validator and Search are
>>> using it already.
>>> I not they should at least in my opinion.
>>>
>>> --Hardy
>>>
>>> On Fri, 18 Mar 2011 19:13:01 +0100, Steve Ebersole <steve(a)hibernate.org>
>>> wrote:
>>>
>>>> I will be changing Hibernate Core JIRA project to use the
>>>> participant-based
>>>> notification scheme. Should I change over any other projects while I am
>>>> in
>>>> there?
>>>>
>>>> What is participant-based notification? Basically, any participant
>>>> (reporter,
>>>> assignee and all commenters) is automatically notified on changes.
>>>>
>>>> ---
>>>> Steve Ebersole <steve(a)hibernate.org>
>>>> http://hibernate.org
>>>> _______________________________________________
>>>> hibernate-dev mailing list
>>>> hibernate-dev(a)lists.jboss.org
>>>> https://lists.jboss.org/mailman/listinfo/hibernate-dev
>>> _______________________________________________
>>> hibernate-dev mailing list
>>> hibernate-dev(a)lists.jboss.org
>>> https://lists.jboss.org/mailman/listinfo/hibernate-dev
>>>
>>
>>
> _______________________________________________
> hibernate-dev mailing list
> hibernate-dev(a)lists.jboss.org
> https://lists.jboss.org/mailman/listinfo/hibernate-dev
--
Galder Zamarreño
Sr. Software Engineer
Infinispan, JBoss Cache
15 years
Need RemoteCacheManager.getCacheNames() for Spring integration
by Olaf Bergner
I have more or less finished my first attempt at implementing Spring
3.1's forthcoming cache abstraction for Infinispan embedded. While doing
the same for Infinispan remote, i.e. for Infinispan's hotrod client, I
noticed that org.infinispan.client.hotrod.RemoteCacheManager lacks a
method for asking it for the names of all caches that are currently
known to it. This, however, is required for successfully implementing
org.springframework.cache.CacheManager. For now, I work around this
limitation by using reflection to get at RemoteCacheManager's map from
cache names to caches. Suffice it to say that this reeks of a hack.
So do you think that adding such a method to RemoteCacheManager is
feasible? Alternatively, do you know of any other way to get at the
names of all caches managed by RemoteCacheManager?
Cheers,
Olaf
15 years
use %s syntax for formatting exception messages
by Mircea Markus
Hi,
Not a biggie, but I think it would be nice to use this nicer syntax for exception messages, e.g.
throw new ConfigurationException("you 're not allowed to use %s and %s together", that, other);
wdyt?
Cheers,
Mircea
15 years
SysAdmin operations for recovering transactions
by Mircea Markus
Hi,
It's about the stage where TM's recovery process finds a in-doubt transaction and notifies the sys admin about it: what hooks does ISPN provide to the sys admin in order to "fix" the tx.
E.g. step >= 3.3 : http://community.jboss.org/servlet/JiveServlet/showImage/102-16552-14-118...
Here is what I have in mind:
Expose (JMX) two operations:
//all the params together fully describe a xid.
replayTx(byte[] txBranch, byte[] txId, int formatId);
forceRollbackTx(byte[] txBranch, byte[] txId, int formatId);
Here is how these two ops would work:
A. replayTx
1. the node has locally the PrepareCommand associated with that XID
- re-issues a prepare: TransactionXAResource.prepare
- if successful re-issues a commit: TransactionXAResource.commit
-if failure happens at any step the user is informed and she/he can re-do the JMX call
- if success the recovery information is removed from the cluster (async)
2. the node doesn't have the PrepareCommand associated with that XID
- broadcast ReplayTxCommand (Xid)
- when a node receives ReplayTxCommand
- if doesn't have a PreparedCommand associated with the Xid ignores it
- if has a PreparedCommand...
- is it the first in the view that has it [1]?
- yes. Execute A.1then returns result to node that broadcasted ReplayTxCommand. This is guaranteed to happen on at most[2] one node in the cluster
- no. Ignores it.
- if success the recovery information is removed from the cluster (async)
B.rollbackTx
- node broadcasts RollbackCommand
- each node that has the PrepareCommand forces a rollback
- each node that doesn't have the PreparedCommand ignores it
- if success the recovery information is removed from the cluster (async)
Cheers,
Mircea
[1] this is determined by building the set of nodes on which tx spreads, based on tx's state. Then determine the first in the view.
[2] it is possible not to happen on any node as the PrepareCommand might had been removed from all nodes in between (node failures, expiration from the recovery cache).
15 years
