[jboss-user] [Beginner's Corner] - Interceptor issue

[sri2]

sri2 [https://community.jboss.org/people/sri2] created the discussion

"Interceptor issue"

To view the discussion, visit: https://community.jboss.org/message/820493#820493

--------------------------------------------------------------
Hi,

I created an interceptor extending from *BasicCustomInterceptor* implementing with *MBean* with simple methods.
Initialized/Uninitiazed in *start* and *stop* overrided methods. It accesses these methods when creating and destroying bean.
Somehow it has *not* accessed to *visitDistributedExecuteCommand* override method where my logic reside to compute something in distributed mode with numOwners=2. If I override other methods like *visitPutKeyValueCommand* then it accesses.
To find the issue, I added some couple of methods by putting print out statement along *return invokeNextInterceptor(ctx, command)* Just for testing purpose. These methods are : 

1)//Not Accessed
@Override
    public Object visitSizeCommand(InvocationContext ctx, SizeCommand command)  throws Throwable {

        System.out.println("Inside visitSizeCommand");
        return invokeNextInterceptor(ctx, command);        
    }
2) //Not Accessed
@Override
public void visitCollection(InvocationContext ctx,  Collection<? extends VisitableCommand> toVisit) throws Throwable {
        System.out.println("Inside visitCollection");
//        debug("Collection Size: " + toVisit.size() );
 }

3) //Not Accessed
@Override
public  <V> Object visitDistributedExecuteCommand(InvocationContext ctx, DistributedExecuteCommand<V> command) throws Throwable {
        System.out.println("++++++++++++Inside visitDistributedExecuteCommand()");
        Object o = invokeNextInterceptor(ctx, command);
        // Some logic here
        return o;
    }

4) // Accessed
@Override
       public Object visitPutKeyValueCommand(InvocationContext ctx, PutKeyValueCommand cmd) throws Throwable {
          System.out.println("Ignoring this call to enforce read-only behavior");
          return invokeNextInterceptor(ctx, cmd);

       }

5) // Accessed
 @Override
       visitRemoveCommand(InvocationContext ctx, RemoveCommand cmd) throws Throwable {
          System.out.println("Visited::::visitRemoveCommand");
         return invokeNextInterceptor(ctx, cmd);
       }

I'm using 5.3.0.Beta1 version with JDK 1.7.0_04. Interceptor added in config file. Testing with PiApproximationDemo and also with SimpleCache ( book, pay and list ) Infinispan book example.

Please advice how do I make it access to *visitDistributedExecuteCommand* override method. 
And also advice how do I access to individual statistics from each node in distributed environment and show it on RHQ monitor/JConsole/JVisualVM by using MBeans or MXBeans.*
* 
Do I have to write a plug in for RHQ? Or Do I have to write purely JMX code? I have to see each node info in addition to  these statistics from URL  http://docs.jboss.org/infinispan/5.1/apidocs/jmxComponents.html#Statistics http://docs.jboss.org/infinispan/5.1/apidocs/jmxComponents.html#Statistics.
Any input and code examples are appreciated. Thanks in Advance. 
Sri

Partial Config file:

    <global>
           <transport>         
            <properties>             
            <property name="configurationFile" value="jgroups.xml"/>
            </properties>       
        </transport>
    </global>  
   <default>      
       <clustering mode="distribution">       
       <sync/>       
       <hash numOwners="2"/>    
      </clustering> 

      <customInterceptors>
         <interceptor class="com.xxx.xxx.TestInterceptor" position="FIRST" />
      </customInterceptors>      
   </default>

*Output from SimpleCache Example:*

May 30, 2013 3:31:11 PM org.infinispan.remoting.transport.jgroups.JGroupsTransport start
INFO: ISPN000078: Starting JGroups Channel
May 30, 2013 3:31:11 PM org.jgroups.logging.JDKLogImpl warn
WARNING: [JGRP00014] TP.discard_incompatible_packets has been deprecated: incompatible packets are discarded anyway
May 30, 2013 3:31:11 PM org.jgroups.logging.JDKLogImpl warn
WARNING: [JGRP00014] TP.enable_bundling has been deprecated: will be ignored as bundling is on by default
May 30, 2013 3:31:11 PM org.jgroups.logging.JDKLogImpl warn
WARNING: [JGRP00014] UNICAST.setTimeout has been deprecated: not used anymore
May 30, 2013 3:31:14 PM org.infinispan.remoting.transport.jgroups.JGroupsTransport viewAccepted
INFO: ISPN000094: Received new cluster view: [xxxx]
May 30, 2013 3:31:14 PM org.infinispan.remoting.transport.jgroups.JGroupsTransport startJGroupsChannelIfNeeded
INFO: ISPN000079: Cache local address is xxxx, physical addresses are [xxx]
May 30, 2013 3:31:14 PM org.infinispan.factories.GlobalComponentRegistry start
INFO: ISPN000128: Infinispan version: Infinispan 'Tactical Nuclear Penguin' 5.3.0.Beta1
*************registering MBean: com.xxx.xxx:type=TestInterceptor
********* Printing Interceptors from interceptorChain
********* Interceptor name: com.xxx.xxx.TestInterceptor
********* Interceptor name: org.infinispan.interceptors.InvocationContextInterceptor
********* Interceptor name: org.infinispan.statetransfer.StateTransferInterceptor
********* Interceptor name: org.infinispan.statetransfer.TransactionSynchronizerInterceptor
********* Interceptor name: org.infinispan.interceptors.NotificationInterceptor
********* Interceptor name: org.infinispan.interceptors.locking.NonTransactionalLockingInterceptor
********* Interceptor name: org.infinispan.interceptors.EntryWrappingInterceptor
********* Interceptor name: org.infinispan.interceptors.distribution.NonTxConcurrentDistributionInterceptor
********* Interceptor name: org.infinispan.interceptors.CallInterceptor
May 30, 2013 3:31:14 PM org.infinispan.jmx.CacheJmxRegistration start
INFO: ISPN000031: MBeans were successfully registered to the platform MBean server.
Ticket booking system
=====================
Commands: book, pay, list
> book
Enter name aaa
Enter show 111
Visited::::visitPutKeyValueCommand 
Booked ticket Ticket{name='aaa', show='111'}
> book
Enter name bbb
Enter show 222
Visited::::visitPutKeyValueCommand 
Booked ticket Ticket{name='bbb', show='222'}
> list
Ticket{name='aaa', show='111'}
Ticket{name='bbb', show='222'}
> pay
Enter ticketid 1
Visited::::visitRemoveCommand 
Checked out ticket Ticket{name='aaa', show='111'}
>
--------------------------------------------------------------

Reply to this message by going to Community
[https://community.jboss.org/message/820493#820493]

Start a new discussion in Beginner's Corner at Community
[https://community.jboss.org/choose-container!input.jspa?contentType=1&containerType=14&container=2075]

-------------- next part --------------
An HTML attachment was scrubbed...
URL: http://lists.jboss.org/pipermail/jboss-user/attachments/20130530/e9e8957f/attachment-0001.html