[JBoss JIRA] (ISPN-19) different cache manager impl : LocalCacheManager and ClusteredCacheManager
by Mircea Markus (JIRA)
[ https://issues.jboss.org/browse/ISPN-19?page=com.atlassian.jira.plugin.sy... ]
Mircea Markus updated ISPN-19:
------------------------------
Priority: Minor (was: Major)
> different cache manager impl : LocalCacheManager and ClusteredCacheManager
> --------------------------------------------------------------------------
>
> Key: ISPN-19
> URL: https://issues.jboss.org/browse/ISPN-19
> Project: Infinispan
> Issue Type: Feature Request
> Components: Core API
> Reporter: Mircea Markus
> Assignee: Manik Surtani
> Priority: Minor
>
> consider having two CacheManagers impl: LocalCacheaManager and ClusteredCacheManager.
> This is in order to offer a more clear API to the user, who might want to use a specific cache manager.
> Currently, this is achieved through usage of GlobalConfiguration.getClusterDefault()/getNonClusterDefault(), but this is not very clear to the user.
> Also, after trying to create an replicated cache on a cache manager build on an "getNonClusterDefault" config, there will be an unclear error message:
> ""Caused by: java.lang.reflect.InvocationTargetException
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
> at java.lang.reflect.Method.invoke(Method.java:585)
> at org.horizon.util.ReflectionUtil.invokeAccessibly(ReflectionUtil.java:129)
> ... 35 more
> Caused by: java.lang.NullPointerException
> at org.horizon.statetransfer.StateTransferManagerImpl.start(StateTransferManagerImpl.java:116)
> ... 40 more
> Error should be more specific, something like: "You're not allowed to deploy an clustered cache on an local cache manager".
> public void testCreateReplicatedCacheOnLocalCM() {
> GlobalConfiguration globalConfiguration = GlobalConfiguration.getNonClusteredDefault();
> globalConfiguration.setAllowDuplicateDomains(true);
> CacheManager dcm1 = new DefaultCacheManager(globalConfiguration);
> CacheManager dcm2 = new DefaultCacheManager(globalConfiguration);
> Configuration conf = new Configuration();
> conf.setCacheMode(Configuration.CacheMode.REPL_SYNC);
> dcm1.defineCache("replicated", conf);
> dcm2.defineCache("replicated", conf);
> dcm1.getCache("replicated");
> dcm2.getCache("replicated");
> }
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
12 years, 9 months
[JBoss JIRA] (ISPN-2902) document exception handling in Infinispan
by Mircea Markus (JIRA)
[ https://issues.jboss.org/browse/ISPN-2902?page=com.atlassian.jira.plugin.... ]
Mircea Markus updated ISPN-2902:
--------------------------------
Fix Version/s: (was: 6.0.0.Final)
> document exception handling in Infinispan
> -----------------------------------------
>
> Key: ISPN-2902
> URL: https://issues.jboss.org/browse/ISPN-2902
> Project: Infinispan
> Issue Type: Task
> Affects Versions: 5.2.3.Final
> Reporter: Mircea Markus
> Assignee: Mircea Markus
>
> Map/ConcurrentMap operations, as overridden by Infinispan, might throw various runtime exception to the user. These exceptions should be:
> - documented (API)
> - the user should be informed about what happens in the case of any such exceptions being thrown (e.g. the operation hasn't succeed an all nodes, the cache might be inconsistent, etc). This again should be added in the javadoc
> (ISPN-629 did part of the job for TimeoutException)
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
12 years, 9 months
[JBoss JIRA] (ISPN-2432) enhance distributed executor service with submit(Task, Address...)
by Mircea Markus (JIRA)
[ https://issues.jboss.org/browse/ISPN-2432?page=com.atlassian.jira.plugin.... ]
Mircea Markus commented on ISPN-2432:
-------------------------------------
As a workaround you can use: DistributedExecutorService.submit(DistributedTask<T> task, K... input) and generate the input keys with the KeyAffinityService in order to match the needed addresses.
> enhance distributed executor service with submit(Task, Address...)
> ------------------------------------------------------------------
>
> Key: ISPN-2432
> URL: https://issues.jboss.org/browse/ISPN-2432
> Project: Infinispan
> Issue Type: Feature Request
> Components: Distributed Execution and Map/Reduce
> Affects Versions: 5.2.0.Beta2
> Reporter: Mathieu Lachance
> Assignee: Vladimir Blagojevic
>
> as discussed with vladimir on user forum it would be nice to add to the DistributedExecutorService interface (or Advanced interface) a capability to submit a task to a particular address(es).
> my use case was to propagate a cdi event to all other members to the cluster as the local dispatch was already ensured with @Observes.
> basically I wanted to do the following :
> {code:java}
> @Inject Event<MyEventThatIWantToPropagateThatExtendsBaseEvent> myEvent;
> myEvent.fire(new MyEvent());
> @Inject BeanManager beanManager;
> onBaseEvent(@Observes final BaseEvent event){
> List<Address> addresses = getAllOtherNodes();
> DistributedExecutorService.submit(new Callable<Void>({
> public Void run() throws Exception{
> beanManager.fireEvent(event);
> }
> }), addresses);
> }
> onMyEvent(@Observes final MyEvent event){
> System.out.println("this will be executed locally and on all other members of the cluster");
> }
> {code}
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
12 years, 9 months
[JBoss JIRA] (ISPN-2432) enhance distributed executor service with submit(Task, Address...)
by Mircea Markus (JIRA)
[ https://issues.jboss.org/browse/ISPN-2432?page=com.atlassian.jira.plugin.... ]
Mircea Markus updated ISPN-2432:
--------------------------------
Priority: Minor (was: Major)
> enhance distributed executor service with submit(Task, Address...)
> ------------------------------------------------------------------
>
> Key: ISPN-2432
> URL: https://issues.jboss.org/browse/ISPN-2432
> Project: Infinispan
> Issue Type: Feature Request
> Components: Distributed Execution and Map/Reduce
> Affects Versions: 5.2.0.Beta2
> Reporter: Mathieu Lachance
> Assignee: Vladimir Blagojevic
> Priority: Minor
>
> as discussed with vladimir on user forum it would be nice to add to the DistributedExecutorService interface (or Advanced interface) a capability to submit a task to a particular address(es).
> my use case was to propagate a cdi event to all other members to the cluster as the local dispatch was already ensured with @Observes.
> basically I wanted to do the following :
> {code:java}
> @Inject Event<MyEventThatIWantToPropagateThatExtendsBaseEvent> myEvent;
> myEvent.fire(new MyEvent());
> @Inject BeanManager beanManager;
> onBaseEvent(@Observes final BaseEvent event){
> List<Address> addresses = getAllOtherNodes();
> DistributedExecutorService.submit(new Callable<Void>({
> public Void run() throws Exception{
> beanManager.fireEvent(event);
> }
> }), addresses);
> }
> onMyEvent(@Observes final MyEvent event){
> System.out.println("this will be executed locally and on all other members of the cluster");
> }
> {code}
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
12 years, 9 months
[JBoss JIRA] (ISPN-2432) enhance distributed executor service with submit(Task, Address...)
by Mircea Markus (JIRA)
[ https://issues.jboss.org/browse/ISPN-2432?page=com.atlassian.jira.plugin.... ]
Mircea Markus resolved ISPN-2432.
---------------------------------
Resolution: Duplicate Issue
implemented as part of ISPN-1974.
> enhance distributed executor service with submit(Task, Address...)
> ------------------------------------------------------------------
>
> Key: ISPN-2432
> URL: https://issues.jboss.org/browse/ISPN-2432
> Project: Infinispan
> Issue Type: Feature Request
> Components: Distributed Execution and Map/Reduce
> Affects Versions: 5.2.0.Beta2
> Reporter: Mathieu Lachance
> Assignee: Vladimir Blagojevic
>
> as discussed with vladimir on user forum it would be nice to add to the DistributedExecutorService interface (or Advanced interface) a capability to submit a task to a particular address(es).
> my use case was to propagate a cdi event to all other members to the cluster as the local dispatch was already ensured with @Observes.
> basically I wanted to do the following :
> {code:java}
> @Inject Event<MyEventThatIWantToPropagateThatExtendsBaseEvent> myEvent;
> myEvent.fire(new MyEvent());
> @Inject BeanManager beanManager;
> onBaseEvent(@Observes final BaseEvent event){
> List<Address> addresses = getAllOtherNodes();
> DistributedExecutorService.submit(new Callable<Void>({
> public Void run() throws Exception{
> beanManager.fireEvent(event);
> }
> }), addresses);
> }
> onMyEvent(@Observes final MyEvent event){
> System.out.println("this will be executed locally and on all other members of the cluster");
> }
> {code}
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
12 years, 9 months
[JBoss JIRA] (ISPN-2432) enhance distributed executor service with submit(Task, Address...)
by Mircea Markus (JIRA)
[ https://issues.jboss.org/browse/ISPN-2432?page=com.atlassian.jira.plugin.... ]
Mircea Markus reopened ISPN-2432:
---------------------------------
ISPN-1974 only covers a single address.
> enhance distributed executor service with submit(Task, Address...)
> ------------------------------------------------------------------
>
> Key: ISPN-2432
> URL: https://issues.jboss.org/browse/ISPN-2432
> Project: Infinispan
> Issue Type: Feature Request
> Components: Distributed Execution and Map/Reduce
> Affects Versions: 5.2.0.Beta2
> Reporter: Mathieu Lachance
> Assignee: Vladimir Blagojevic
>
> as discussed with vladimir on user forum it would be nice to add to the DistributedExecutorService interface (or Advanced interface) a capability to submit a task to a particular address(es).
> my use case was to propagate a cdi event to all other members to the cluster as the local dispatch was already ensured with @Observes.
> basically I wanted to do the following :
> {code:java}
> @Inject Event<MyEventThatIWantToPropagateThatExtendsBaseEvent> myEvent;
> myEvent.fire(new MyEvent());
> @Inject BeanManager beanManager;
> onBaseEvent(@Observes final BaseEvent event){
> List<Address> addresses = getAllOtherNodes();
> DistributedExecutorService.submit(new Callable<Void>({
> public Void run() throws Exception{
> beanManager.fireEvent(event);
> }
> }), addresses);
> }
> onMyEvent(@Observes final MyEvent event){
> System.out.println("this will be executed locally and on all other members of the cluster");
> }
> {code}
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
12 years, 9 months
[JBoss JIRA] (ISPN-2432) enhance distributed executor service with submit(Task, Address...)
by Mircea Markus (JIRA)
[ https://issues.jboss.org/browse/ISPN-2432?page=com.atlassian.jira.plugin.... ]
Mircea Markus updated ISPN-2432:
--------------------------------
Description:
as discussed with vladimir on user forum it would be nice to add to the DistributedExecutorService interface (or Advanced interface) a capability to submit a task to a particular address(es).
my use case was to propagate a cdi event to all other members to the cluster as the local dispatch was already ensured with @Observes.
basically I wanted to do the following :
{code:java}
@Inject Event<MyEventThatIWantToPropagateThatExtendsBaseEvent> myEvent;
myEvent.fire(new MyEvent());
@Inject BeanManager beanManager;
onBaseEvent(@Observes final BaseEvent event){
List<Address> addresses = getAllOtherNodes();
DistributedExecutorService.submit(new Callable<Void>({
public Void run() throws Exception{
beanManager.fireEvent(event);
}
}), addresses);
}
onMyEvent(@Observes final MyEvent event){
System.out.println("this will be executed locally and on all other members of the cluster");
}
{code}
was:
as discussed with vladimir on user forum it would be nice to add to the DistributedExecutorService interface (or Advanced interface) a capability to submit a task to a particular address(es).
my use case was to propagate a cdi event to all other members to the cluster as the local dispatch was already ensured with @Observes.
basically I wanted to do the following :
@Inject Event<MyEventThatIWantToPropagateThatExtendsBaseEvent> myEvent;
myEvent.fire(new MyEvent());
@Inject BeanManager beanManager;
onBaseEvent(@Observes final BaseEvent event){
List<Address> addresses = getAllOtherNodes();
DistributedExecutorService.submit(new Callable<Void>({
public Void run() throws Exception{
beanManager.fireEvent(event);
}
}), addresses);
}
onMyEvent(@Observes final MyEvent event){
System.out.println("this will be executed locally and on all other members of the cluster");
}
> enhance distributed executor service with submit(Task, Address...)
> ------------------------------------------------------------------
>
> Key: ISPN-2432
> URL: https://issues.jboss.org/browse/ISPN-2432
> Project: Infinispan
> Issue Type: Feature Request
> Components: Distributed Execution and Map/Reduce
> Affects Versions: 5.2.0.Beta2
> Reporter: Mathieu Lachance
> Assignee: Vladimir Blagojevic
>
> as discussed with vladimir on user forum it would be nice to add to the DistributedExecutorService interface (or Advanced interface) a capability to submit a task to a particular address(es).
> my use case was to propagate a cdi event to all other members to the cluster as the local dispatch was already ensured with @Observes.
> basically I wanted to do the following :
> {code:java}
> @Inject Event<MyEventThatIWantToPropagateThatExtendsBaseEvent> myEvent;
> myEvent.fire(new MyEvent());
> @Inject BeanManager beanManager;
> onBaseEvent(@Observes final BaseEvent event){
> List<Address> addresses = getAllOtherNodes();
> DistributedExecutorService.submit(new Callable<Void>({
> public Void run() throws Exception{
> beanManager.fireEvent(event);
> }
> }), addresses);
> }
> onMyEvent(@Observes final MyEvent event){
> System.out.println("this will be executed locally and on all other members of the cluster");
> }
> {code}
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
12 years, 9 months
[JBoss JIRA] (ISPN-2432) enhance distributed executor service with submit(Task, Address...)
by Mircea Markus (JIRA)
[ https://issues.jboss.org/browse/ISPN-2432?page=com.atlassian.jira.plugin.... ]
Mircea Markus updated ISPN-2432:
--------------------------------
Fix Version/s: (was: 6.0.0.Final)
> enhance distributed executor service with submit(Task, Address...)
> ------------------------------------------------------------------
>
> Key: ISPN-2432
> URL: https://issues.jboss.org/browse/ISPN-2432
> Project: Infinispan
> Issue Type: Feature Request
> Components: Distributed Execution and Map/Reduce
> Affects Versions: 5.2.0.Beta2
> Reporter: Mathieu Lachance
> Assignee: Vladimir Blagojevic
>
> as discussed with vladimir on user forum it would be nice to add to the DistributedExecutorService interface (or Advanced interface) a capability to submit a task to a particular address(es).
> my use case was to propagate a cdi event to all other members to the cluster as the local dispatch was already ensured with @Observes.
> basically I wanted to do the following :
> @Inject Event<MyEventThatIWantToPropagateThatExtendsBaseEvent> myEvent;
> myEvent.fire(new MyEvent());
> @Inject BeanManager beanManager;
> onBaseEvent(@Observes final BaseEvent event){
> List<Address> addresses = getAllOtherNodes();
> DistributedExecutorService.submit(new Callable<Void>({
> public Void run() throws Exception{
> beanManager.fireEvent(event);
> }
> }), addresses);
> }
> onMyEvent(@Observes final MyEvent event){
> System.out.println("this will be executed locally and on all other members of the cluster");
> }
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
12 years, 9 months