I'm trying to add and run a test
* https://gist.github.com/alesj/f2b48b3697a6252777f4
https://gist.github.com/alesj/f2b48b3697a6252777f4
Yet it never finishes ...
* https://gist.github.com/alesj/ea912570bc72cb4073f9
https://gist.github.com/alesj/ea912570bc72cb4073f9
My branch
*
Ales, I don't think the implementation matters that much, I was only
concerned about the API. BTW, where could I find some documentation on MSC?
Perhaps check this?
https://docs.jboss.org/author/display/MSC/Home
-Ales
___
infinispan-dev mailing
What about if you add an SPI for this?
e.g. this could be nicely implemented on top of WildFly's MSC
And by default you would keep this simple incRef,
or some similar simple state machine we used in Microcontainer.
-Ales
On 15 Aug 2014, at 16:26, Sanne Grinovero sa...@infinispan.org wrote:
To compare, I reconfigured it to use local-only NTR backends (not
suited for clustering) and so doing I found another problem: all of
your caches are sharing the same index!
By reconfiguring each cache to use and independent path to isolate the
indexes, the benchmark completes in 20 seconds,
So, storing some thousand entities in a single transaction takes a
little more than 1 second, while running each put operation in a
single transaction takes ~50 seconds.
For the record, I'm more concerned that storing a few thousand
entities in a single TX takes a full second: that's not
Here:
---
I've added this test to GAE TCK:
*
https://github.com/GoogleCloudPlatform/appengine-tck/blob/master/core/benchmark/src/test/java/com/google/appengine/tck/benchmark/ObjectifyBenchmarkTest.java
You need CapeDwarf 2.0.0.CR2:
* http://capedwarf.org/downloads/
And clone GAE TCK:
*
Was there ever any attempt to bridge Infinispan and Quartz?
* http://quartz-scheduler.org/documentation/faq#FAQ-clustering
As I'll probably need it for this:
* https://developers.google.com/appengine/docs/java/config/cron
If nothing exists, I'll have a crack at it.
-Ales
, Ales Justin ales.jus...@gmail.com wrote:
Was there ever any attempt to bridge Infinispan and Quartz?
* http://quartz-scheduler.org/documentation/faq#FAQ-clustering
As I'll probably need it for this:
* https://developers.google.com/appengine/docs/java/config/cron
If nothing exists, I'll have
- also important to notice that we will have both an Hadoop and an Infinispan
cluster running in parallel: the user will interact with the former in order
to run M/R tasks. Hadoop will use Infinispan (integration achieved through
InputFormat and OutputFormat ) in order to get the data to be
Just having a discussion with Bela about this.
I guess having grouping on GridFS' content would make sense.
e.g. put all chunks on the same node
Is this doable?
Afaiu, we would need to have some sort of similarity function for content's
metadata?
-Ales
+1 Are you in Slovenia?
No, just an IRC chat with me. :-)
To add to this link:
* http://en.wikipedia.org/wiki/Olm
On 3/5/2014, 10:26 AM, Bela Ban wrote:
https://www.facebook.com/HumanFishBrewery
___
infinispan-dev mailing list
I'm looking at current WildFly integration.
In CacheAdd I see this code:
if ((lockingMode == LockingMode.OPTIMISTIC) (isolationLevel ==
IsolationLevel.REPEATABLE_READ)) {
builder.locking().writeSkewCheck(true);
}
but then locking has this validation:
public
Ok, noted.
-Ales
On Oct 3, 2013, at 17:44, Sanne Grinovero sa...@infinispan.org wrote:
Hi,
just a heads up that I've been moving some APIs around from
org.infinispan.query:
https://github.com/infinispan/infinispan/pull/2131
In particular I think that CapeDwarf is using some methods
Anything obvious on why this lookup doesn't find its match?
Some background:
* I have .ear, with 2 .war sub-deployments
* each .war has own Key class in own gae.jar (in WEB-INF/lib)
I do set storeAsBinary on the cache, which is shared between both .wars.
This first key is the key for 2nd
@InSequence(2)
@OperateOnModule(m2)
public void testGet() throws Exception {
Key key = KeyFactory.createKey(MODULES_KIND, 1);
Entity e = ds.get(key);
Assert.assertNotNull(e);
}
-Ales
On Aug 6, 2013, at 12:22 AM, Ales Justin ales.jus...@gmail.com wrote:
Anything obvious
So you're saying that while this state transfer was going on, some other
process (another thread) changed this value?
Any way to avoid this?
Global lock is fine, for now.
-Ales
On Jul 15, 2013, at 4:36 PM, Mircea Markus mmar...@redhat.com wrote:
A WriteSkewCheck exception is thrown by an
So you're saying that while this state transfer was going on, some other
process (another thread) changed this value?
The functionality I've described is not related to the state transfer in
particular, but has to do with how optimistic transactions work.
Was there a state transfer in
Human Fish
* https://www.facebook.com/HumanFishBrewery
On Jun 17, 2013, at 10:37 PM, Mircea Markus mmar...@redhat.com wrote:
Hi,
Following the tradition, each Infinispan release is code is a beer.
Suggestions?
I'll start:
- Infinium
Cheers,
--
Mircea Markus
Infinispan lead
And it looks like this change results in mem leak as well ...
On May 7, 2013, at 6:53 PM, Dan Berindei dan.berin...@gmail.com wrote:
On Fri, May 3, 2013 at 1:49 PM, Galder Zamarreño gal...@redhat.com wrote:
Here's what I replied in a separate email last. Since then the issue has been
We - CapeDwarf - are also working on some changes,
which modify API a bit, so it's good to get this in asap,
before things go into some CR.
I'll let Marko add the details.
But as he tells me, we should be done before 1. May.
-Ales
Hi,
Galder has just issued a rather large pull request on
@Bela -- I can help you setup the whole CD env. ;-)
On Apr 15, 2013, at 7:14 AM, Bela Ban b...@redhat.com wrote:
On 4/13/13 1:42 PM, Sanne Grinovero wrote:
On 13 April 2013 11:20, Bela Ban b...@redhat.com wrote:
On 4/13/13 2:02 AM, Sanne Grinovero wrote:
@All, the performance
Does CD also change the JGroups configuration? I thought it only tweaks the
Infinispan cache configuration on deployment, and the JGroups channel is
already started by the time the CD application is deployed.
CD uses a custom AS build and a custom AS configuration, so anything
could be
Looking at your workaround, I think you actually set the response mode to
GET_NONE (because that's the default value in RequestOptions), so you're back
to sending an asynchronous request.
That was my question as well:
Shouldn't this synchronous flag still be used?
it interesting to
figure what was going on! Also I'm wondering how hard it would be to
have a log parser which converts my 10GB of text log from today in a
graphical sequence diagram.
Big thanks to Mircea who helped me figuring this out.
Sanne
On 12 April 2013 21:10, Ales Justin ales.jus
=
dispatcher.getChannel().getView().getMembers().size();
RequestOptions options = RequestOptions.SYNC();
options.setRspFilter( new WaitAllFilter( size ) );
} else {
options = RequestOptions.ASYNC();
}
-Ales
On Apr 13, 2013, at 11:25 AM, Ales Justin
There are lots of complex moving parts in this scenario: from a Muxed
JGroups Channel, and the Application Server responsible for
initializing the stack with some added magic from CapeDwarf itself:
it's not clear to me what configuration is exactly being used, for
one.
Some quick info on
-test__com.google.appengine.api.datastore.Entity'
11:20:54,730 INFO [org.jboss.web] (ServerService Thread Pool -- 59)
JBAS018224: Unregister web context: /capedwarf-tests
On Apr 12, 2013, at 9:43 AM, Bela Ban b...@redhat.com wrote:
You need to set enable_bundling to *false*, not true !
On 4/11/13 9:13 PM, Ales
.
But, if I add 2sec sleep between delete and query, it works.
Which makes me wonder why the additional 48sec, for something that works in
~2sec.
-Ales
On 4/12/13 11:21 AM, Ales Justin wrote:
Still the same -- after changing this to false.
11:20:04,013 INFO
:21 AM, Ales Justin wrote:
Still the same -- after changing this to false.
11:20:04,013 INFO
[org.hibernate.search.indexes.impl.DirectoryBasedIndexManager]
(http-/192.168.30.235:8080-2) HSEARCH000168: Serialization service
Avro SerializationProvider v1.0 being used for index
not what is going on.
I can't explain one index operation taking 50s if nothing is happening
in parallel.
As Sanne said, use the blackhole backend on your index master node. We
will know if the index is really taking all that time.
Emmanuel
On Fri 2013-04-12 14:19, Ales Justin wrote
help you with
better configuration options.
On 11 April 2013 20:47, Ales Justin ales.jus...@gmail.com wrote:
What do you mean?
On Apr 11, 2013, at 21:41, Sanne Grinovero sa...@hibernate.org wrote:
You could try the new sync version but setting the blackhole backend on the
master node
Although this change fixes query lookup,
it adds horrible performance:
Running CapeDwarf cluster QueryTest:
with HSEARCH-1296
21:00:27,188 INFO
[org.hibernate.search.indexes.impl.DirectoryBasedIndexManager]
(http-/192.168.1.102:8080-1) HSEARCH000168: Serialization service Avro
to the
index in the measured interval?
On Apr 11, 2013 8:13 PM, Ales Justin ales.jus...@gmail.com wrote:
Although this change fixes query lookup,
it adds horrible performance:
Running CapeDwarf cluster QueryTest:
with HSEARCH-1296
21:00:27,188 INFO
wrote:
Are you sure that the async version actually had applied all writes to the
index in the measured interval?
On Apr 11, 2013 8:13 PM, Ales Justin ales.jus...@gmail.com wrote:
Although this change fixes query lookup,
it adds horrible performance:
Running CapeDwarf cluster QueryTest
. If CapeDwarf
can live with it it will be better off.
An alternative solution would be to create a JGroups backend that waits
for an execution ACK before giving back the had to the client but that
will have scalability problems.
Emmanuel
On Tue 2013-04-09 23:41, Ales Justin wrote:
Chasing
Message;
that is unless the IM itself is configured to process the index
updates asynchronously, the backend from the client side should block
until the index is updated.
Sanne
On 10 April 2013 13:38, Ales Justin ales.jus...@gmail.com wrote:
@Bela: is there a config way to make this JGroups
Hey Dan,
first, thanks for looking into this!
I managed to start the app with 3 nodes on my laptop, and it inserted a
flight in about 26.7 seconds with TRACE enabled for org.infinispan. However,
when I counted the number of cache commands being executed and I got 55000
(8700 of which went
deployer. Are you seeing
log statements from the excluded categories appearing in the handlers defined
in the WEB-INF/logging.properties file?
On 04/09/2013 12:51 AM, Ales Justin wrote:
Hey Dan,
first, thanks for looking into this!
I managed to start the app with 3 nodes on my
Chasing down today's NPE: http://pastie.org/7382216
I've added this test:
* https://github.com/capedwarf/capedwarf-blue/commit/d416d5358
The test fails. ;-)
deleteAndQueryInA(org.jboss.test.capedwarf.cluster.test.QueryTest): Should not
be here: null
This is the null that is the cause of top
?
On 5 Apr 2013, at 15:28, Ales Justin ales.jus...@gmail.com wrote:
are you not using the JGroups backend anymore?
I'm using that jgroups backend, with auto-master election.
these Lock acquisitions are on the index lock, and make me suspect your
configuration is no longer applying the pattern
.
Sanne
On 8 April 2013 11:38, Manik Surtani msurt...@redhat.com wrote:
On 8 Apr 2013, at 11:28, Ales Justin ales.jus...@gmail.com wrote:
This jgroups backend was there long ago.
And it was actually us - CD - that fixed it and made use of it.
It's no different from static JGroups
Ales is this error happening after a node failure?
No node failure that I'm aware of.
We did get some unexpected NPE in DataNucleus framework,
but, imo, that shouldn't completely kill the app.
We'll re-try.
Now I cannot even open an initial page ...
New error ...
https://gist.github.com/alesj/5336483
-Ales
On Apr 8, 2013, at 2:25 PM, Ales Justin ales.jus...@gmail.com wrote:
Ales is this error happening after a node failure?
No node failure that I'm aware of.
We did get some unexpected NPE in DataNucleus framework,
but, imo
Steps to re-produce:
(1) checkout JBossAS 7.2.0.Final tag -- JBOSS_HOME
(2) build CapeDwarf Shared
https://github.com/capedwarf/capedwarf-shared
(3) build CapeDwarf Blue
https://github.com/capedwarf/capedwarf-blue
(4) build CapeDwarf AS
https://github.com/capedwarf/capedwarf-jboss-as
mvn
into this.
But sometimes users will want to have FINE log level,
meaning a lot more traffic will go into cache.
And then it still shouldn't kill the app -- as it does now.
-Ales
On Apr 8, 2013, at 3:12 PM, Ales Justin ales.jus...@gmail.com wrote:
Steps to re-produce:
(1) checkout JBossAS 7.2.0.Final tag
Hmmm, we now disabled CapeDwarf logging, and it runs a lot better.
what does a lot better mean? Does it run as expected?
Querying data on any node returns in ~30ms.
And it returns correct data. ;-)
We are logging every stuff that goes on,
and then it's up to user to filter it later -- this
?
In such a setup you would not writ much into the logs but you would
still have a huge performance penalty as we would still be generating
the intermediate strings, and Infinispan can be very verbose.
Sanne
On 8 April 2013 15:30, Ales Justin ales.jus...@gmail.com wrote:
Hmmm, we now disabled
Nah, that would also show with standalone testing then, and it doesn't.
Infinispan generates a gazillion more logging opportunities when
clustering is enabled.. if it's enabled but hidden, it would still be
different than standalone.
Ah, ok.
But from Marko's observations, this is not the
to the JGroups indexing backend.
Or is it the Replication timeout for mstruk/capedwarf which is causing
those locking errors?
No idea.
btw: didn't you say you had some new backend mechanism?
Off Infinispan's channel.
-Ales
On 5 April 2013 14:56, Ales Justin ales.jus...@gmail.com wrote:
We're
.
Or is it the Replication timeout for mstruk/capedwarf which is causing
those locking errors?
No idea.
btw: didn't you say you had some new backend mechanism?
Off Infinispan's channel.
-Ales
On 5 April 2013 14:56, Ales Justin ales.jus...@gmail.com wrote:
We're running a GAE HelloOrm2
, at 00:15, Ales Justin wrote:
Any idea how this can happen?
01:06:36,722 ERROR
[org.infinispan.interceptors.InvocationContextInterceptor]
(http-/127.0.0.1:8080-2) ISPN000136: Execution error:
java.lang.IllegalStateException: Entries cannot have null versions
Any idea how this can happen?
01:06:36,722 ERROR [org.infinispan.interceptors.InvocationContextInterceptor]
(http-/127.0.0.1:8080-2) ISPN000136: Execution error:
java.lang.IllegalStateException: Entries cannot have null versions!
at
What if you just make this a component inside ISPN?
On Feb 25, 2013, at 6:42 PM, Galder Zamarreño gal...@redhat.com wrote:
I'm thinking of creating ^. Any objections?
Cheers,
--
Galder Zamarreño
gal...@redhat.com
twitter.com/galderz
Project Lead, Escalante
http://escalante.io
.
Or perhaps some init(Cache cache) on M/R classes, where it can get a hold of
Cache,
which would then expose app' CL, via AC::withClassloader?
-Ales
On 26 Jan 2013, at 21:55, Ales Justin ales.jus...@gmail.com wrote:
Would the thread context classloader be the right thing to use?
It depends how
; note: CapeDwarf runs in both ways - modular and
embedded
-Ales
On 28 Jan 2013, at 14:01, Ales Justin ales.jus...@gmail.com wrote:
Ales - how could we bundle something like this as an AS module and play
nice with modular class loading there?
Well, I would say we're back to that discussion
The classloader used in Groovy classloader constructor is imo wrong.
Unless you would bundle this infinispan-groovy with your app.
But since most of Infinispan comes with AS already, I would also expect this to
be a module, hence no-go.
On Jan 26, 2013, at 21:58, Sanne Grinovero
Would the thread context classloader be the right thing to use?
It depends how Infinispan's M/R code handles setting of TCCL.
Specially in remote invocations.
But I would expect it to work.
Not the best, but good enough. :-)
Or, perhaps it can use ScriptEngine?
What's ScriptEngine?
-Ales
Invoking a few simple tasks quickly drains out a thread pool of size 3.
--
14:41:43,061 WARN [org.infinispan.distexec.DefaultExecutorService]
(notification-thread-0) ISPN07: Failed local execution :
java.util.concurrent.RejectedExecutionException: Current thread pool executor
queue:
I agree.
Perhaps I need to configure timeout better.
Let me check and get back to you.
Sent from my iPad
On Jan 8, 2013, at 16:43, Vladimir Blagojevic vblag...@redhat.com wrote:
On 13-01-08 2:58 PM, Mircea Markus wrote:
On 8 Jan 2013, at 14:00, Ales Justin wrote:
Invoking a few
how many
Justin wrote:
@Vladimir: any idea why the NPE?
OpenShift only, it occurs on a sequence of requests with no delay between
them.
Matej.
On 03/01/13 20:58, Ales Justin wrote:
Can you reproduce this locally?
Or OpenShift only?
Sent from my iPad
On Jan 3, 2013, at 20:01, Matej
I was changing cache config a bit, and got this:
* https://gist.github.com/4130728
private static void verifyCacheHasNoEviction(AdvancedCache?, ? cache) {
if (cache.getConfiguration().getEvictionStrategy().isEnabled())
throw new
=LuceneIndexesLocking mode=SYNC
transaction mode=NONE/
eviction strategy=NONE/
file-store preload=false purge=true/
/replicated-cache
Horrible err msg ...
On Nov 22, 2012, at 12:53 PM, Ales Justin ales.jus...@gmail.com wrote:
I
in the msg. ;-)
I though I was going blind, as requesting cache - the indexing one - clearly
had NONE set as eviction strategy.
On 22 November 2012 12:21, Ales Justin ales.jus...@gmail.com wrote:
Ah, OK, it should really be disabled on Lucene caches:
replicated-cache name
a bug in how ISPN's Query module use it.
Emmanuel
On Fri 2012-10-26 16:09, Ales Justin wrote:
After searching for the needed in haystack, I finally found the problem.
(not to mention complete lack of tests for this *basic* feature ...)
The problem is with queries with offset when you
I'm constantly seeing this CCE while running CapeDwarf cluster tests:
(running 5.2.Beta2 with my iterator offset patch)
17:43:10,175 ERROR [org.infinispan.interceptors.InvocationContextInterceptor]
(OOB-18,null) ISPN000136: Execution error: java.lang.ClassCastException:
After searching for the needed in haystack, I finally found the problem.
(not to mention complete lack of tests for this *basic* feature ...)
The problem is with queries with offset when you iterate over them -- offset is
never taken into account.
There are two possible fixes -- as I see them.
Ales, do you have trace logs for the test so we can figure out how long an
individual entry's preload is taking?
Running just this test takes almost none.
It's the full testsuite that gets stuck at one point, randomly atm.
Hence I suggest to setup the env, rather then decrypting this from
Can we please get a decision on this,
so we try to get something *workable* into next 5.2. release?
-Ales
p.s. since it looks like nobody is using this, apart from CapeDwarf,
my vote goes into replacing/removing the methods
___
infinispan-dev
While thinking about EntityLoader as interface (imo, it should be an interface
...),
just stumbled upon this:
public ListObject load(EntityInfo... entityInfos) {
int size = entityInfos.length;
ArrayListObject list = new ArrayListObject(size);
for (EntityInfo e :
.
I've made a fix candidate[1] which I assigned to Dan. I still get some
failures on Ales' test, but with a different error message.
[1] https://github.com/infinispan/infinispan/pull/1281
Cheers,
Mircea
On 3 Sep 2012, at 10:30, Ales Justin wrote:
Also to add ...
With some more testing
problem as the other problem you reported.
Sanne
On 2 September 2012 20:39, Ales Justin ales.jus...@gmail.com wrote:
Stack trace of the shutdown:
MSC service thread 1-1@1343 prio=5 tid=0xf nid=NA runnable
java.lang.Thread.State: RUNNABLE
Running CapeDwarf cluster tests on 5.2.0.Alpha3:
(which still do not work ...)
Imo, one should never get this CME.
---
Caused by: java.util.ConcurrentModificationException
at
java.util.AbstractList$Itr.checkForComodification(AbstractList.java:372)
[classes.jar:1.6.0_33]
at
After fixing that ISPN-2253:
*
https://github.com/alesj/infinispan/commit/05229f426e829742902de0305488282b8283b8e5
(Sanne is working on even cleaner solution)
It now also looks like our CapeDwarf clustering tests have been (almost) fixed.
It now appears as if one node cannot do proper querying:
this in Ispn Query tests.
-Ales
On Sep 1, 2012, at 3:59 PM, Ales Justin ales.jus...@gmail.com wrote:
Any idea why this is parked and never goes fwd?
As this then blocks any next cache requests -- see blocked thread below.
Could it be the error below?
This only happens when there is already
is invalid in this commit:
*
https://github.com/alesj/jboss-as/commit/e1b73e018367ee7632d19ad383a7d8a83eb2e4da
Any idea?
On Aug 30, 2012, at 1:51 AM, Ales Justin ales.jus...@gmail.com wrote:
I updated AS7 upstream master to run against Ispn upstream master.
But now I get this NPE:
I guess we
, Ales Justin ales.jus...@gmail.com wrote:
Uh, the workaround results in NPE:
23:10:27,160 ERROR
[org.apache.catalina.core.ContainerBase.[jboss.web].[default-host]]
(http-/192.168.1.101:8080-2) Exception sending request initialized lifecycle
event to listener instance of class
could call cache.start() again.
On Aug 25, 2012, at 3:44 PM, Ales Justin wrote:
When running CapeDwarf tests these days I get this broken behavior:
(using: Ispan 5.2.0.Alpha2)
On 1st test all works OK:
* getting the X cache
* passing it to SearchManager (from Ispan Query)
* doing
();
}
}
return cache;
}
Any other idea?
-Ales
On Aug 27, 2012, at 10:51 PM, Ales Justin ales.jus...@gmail.com wrote:
OK, let me try this workaround.
But should Cache::stop also remove it or not?
If yes, I might dig deeper into finding the culprit
Or is this expected behavior? See below on why ...
I actually just saw this now -- I already had an existing CapeDwarf / GAE app
deployed / present.
If I remove the app, the problem goes away.
Afaik, AS7 counts how many times EmbeddedCacheManager (ECM) is being used,
better, its AS7 service is
When running CapeDwarf tests these days I get this broken behavior:
(using: Ispan 5.2.0.Alpha2)
On 1st test all works OK:
* getting the X cache
* passing it to SearchManager (from Ispan Query)
* doing queries, etc
* stopping the X cache on app (aka Arquillian test) undeploy
But when running 2nd
I haven't actually used infinispan-query, so I don't know if
infinispan-core needs to have its classes visible. Can you comment?
https://github.com/capedwarf/capedwarf-jboss-as/blob/master/build/src/main/resources/modules/org/infinispan/main/module.xml
Afaik, it's needed for Infinispan
FYI - I found the underlying issue:
https://issues.jboss.org/browse/ISPN-2182
Ah, yes, the legacy -- current config transformation looks like the biggest
non-tested stuff ever. ;-)
As I've previously had to fix a few similar, if not almost the same, issues
before - wrt indexing.
A
for the 5.2 upgrade today.
On Wed, 2012-07-25 at 13:42 +0200, Ales Justin wrote:
Paul / Richard, any update?
As I need this in, in order to finally release first version of CapeDwarf.
-Ales
Paul/Richard should be integrating it soon.
On Jul 23, 2012, at 11:18 PM, Ales Justin wrote
Paul / Richard, any update?
As I need this in, in order to finally release first version of CapeDwarf.
-Ales
Paul/Richard should be integrating it soon.
On Jul 23, 2012, at 11:18 PM, Ales Justin wrote:
This was released last Friday but due to some glitches, I was only about to
get
This was released last Friday but due to some glitches, I was only about to
get around to blogging about it now: http://goo.gl/lX4Tq
Thanks to everyone in their involvement, particularly Vladimir and Adrian :)
Any plans to get this into AS7.2.0.Alpha1?
@Sanne, Vladimir: a think-task for you two :)
With CapeDwarf we need the following feature -- just the opposite from query
results.
A user has a document, and a set of pre-defined queries.
Now we need to see which queries match the given document.
A dummy impl is to iterate over queries and
I added a workaround for it -- preparing the immutable list in advance.
The patch is already merged, afaik.
But no idea why this is/was actually happening.
On May 16, 2012, at 4:16 PM, Manik Surtani wrote:
Is this still an issue?
On 9 May 2012, at 16:55, Ales Justin wrote:
Anyone ever
gets invoked now.
So, the question is, JGroups bug, or intentional?
-Ales
On May 15, 2012, at 11:13 PM, Ales Justin wrote:
public Object up(Event evt) {
if(corr != null) {
if(!corr.receive(evt)) {
try {
return
Could be that I don't fully understand how this mux stuff should work. :-)
As we've been busting heads since Friday ...
This is the code (see below) that sets up dispatcher, and sets the listener.
As you can see I add the msg listener to dispatcher.
And I use dispatcher's ::getProtocolAdapter
{
return handleUpEvent(evt);
Meaning msg listener only get's hit if corr::receive returns false.
Is this the case ever - with Ispans handles in place - here?
-Ales
On May 14, 2012, at 11:26 PM, Ales Justin wrote:
Could be that I don't fully understand how this mux stuff should work. :-)
As we've
, should no be connected.
Since they solve diff problems, imo.
Anyway, I'm now gonna try and hunt down where plain ML impl of CR somes in ...
-Ales
On Thu, 2012-05-10 at 23:10 +0200, Ales Justin wrote:
If I do subject I get this CNFE, see below.
Looks like I still need a combination of Cache
and hunt down where plain ML impl of CR somes in ...
-Ales
On Thu, 2012-05-10 at 23:10 +0200, Ales Justin wrote:
If I do subject I get this CNFE, see below.
Looks like I still need a combination of Cache::with(CL) -- so this code
sees Key class,
and at the same time I don't want Infinispan
Although the funky part, imo, is why I get the not found ML error only on
query,
and not on pre-loading the content store?
Is the persisted content loaded lazily, on first touch?
-Ales
On May 11, 2012, at 12:21 PM, Ales Justin wrote:
Hmmm, reducing the chain to GAE - Ispan + HS, mocking
FYI -- in case missed
https://community.jboss.org/message/727586#727586
-Ales
___
infinispan-dev mailing list
infinispan-dev@lists.jboss.org
https://lists.jboss.org/mailman/listinfo/infinispan-dev
Using Infinispan 5.1.1.Final in custom AS7 branch.
1) using DistributedExecutorService::submit with non distributable-cache
results in NPE
protected K MapAddress, ListK mapKeysToNodes(K... input) {
DistributionManager dm = cache.getDistributionManager();
MapAddress, ListK
)
to be the standard way of streaming large objects into Infinispan.
Doesn't it fit your bill?
- Olaf
Am 14.10.11 22:29, schrieb Ales Justin:
@Olaf:
Looking at the API you proposed
/ public interface StreamingHandlerK {//
/ / void writeToKey(K key, InputStream largeObject
@Olaf:
Looking at the API you proposed
public interface StreamingHandlerK {
void writeToKey(K key, InputStream largeObject);
OutputStream writeToKey(K key);
InputStream readFromKey(K key);
boolean removeKey(K key);
StreamingHandlerK withFlags(Flag... flags);
}
and
Works for me as well.
From: Stuart Douglas sdoug...@redhat.com
Subject: Re: [infinispan-dev] tccl usage in listeners
To: Pete Muir pm...@redhat.com
Cc: infinispan -Dev List infinispan-dev@lists.jboss.org
Message-ID: 2ac0dd6b-2c44-4e68-8b86-cb819f131...@redhat.com
Content-Type: text/plain;
While working on OpenShift Flex Infinispan demo, we came across a TCCL setup
issue.
---
Looking at the stack trace, and how listener is registered,
I don't see how Ispan+CDI integration can change this behavior:
Imo, it should be Ispan's job to properly change this.
e.g. wrap each listener
Have you also tried to run a test with the listener in
https://github.com/alesj/lhotse/blob/master/javax-cache/src/main/java/org/jboss/lhotse/cache/infinispan/InfinispanCacheListener.java
? The method parameters for onPut, onLoad and onRemove appear to be wrong.
Ah, copy/paste error.
Let
1 - 100 of 101 matches
Mail list logo
