[JBoss Messaging] - Identifying session status before performing actions on it
by Noa Drach
Noa Drach [http://community.jboss.org/people/newway] created the discussion
"Identifying session status before performing actions on it"
To view the discussion, visit: http://community.jboss.org/message/557733#557733
--------------------------------------------------------------
Hello,
I'm trying to see if I can implement a solution to a problem that I have, but if you think I'm looking in the wrong direction - please let me know.
this is a description of my system:
on the server side I have :
1. JBOSS 4.2.3.GA for java 6
2. with JBOSS Messaging 1.4.5.GA
3. and remoting 2.2.3.sp1
i have multiple clients that run as follows:
1. a process run using Java Service Wrapper by Tanuki
2. java code that connect to the server using JNDI lookup
3. CPP code activated through JNI.
the clients receive message from the server and process them in the cpp code and we tracked a bug that we have to the fact that multiple clients are handling the same message.
after some digging up it looks like the connection to client A is lost after it receives the message and starts handling it and so the JMS redelivers the message to client B.
when client A tries to commit is response to the session we get an exception, but it's too late since the cpp part already committed it's work.
*so what I wanted to know is if there is a way to query a session and see that it's still valid, or if you have an explanation as to why the connection is lost and what I need to do to prevent this*.
Here are some of the messages we get -
Server side:
> 2010-08-16 16:10:35,468 DEBUG [org.jboss.remoting.ConnectionNotifier] mailto:org.jboss.remoting.ConnectionNotifier@d77a85 org.jboss.remoting.ConnectionNotifier@d77a85 Server connection lost to client (session id = 3m3b533o-il79jy-gcxc7el5-1-gcxc7fmx-4
>
> 2010-08-16 16:10:35,468 DEBUG [org.jboss.jms.server.remoting.JMSServerInvocationHandler] removing callback handler ServerInvokerCallbackHandler[3m3b533o-il79jy-gcxc7el5-1-gcxc7fmx-4+3m3b533o-il79jy-gcxc7el5-1-gcxc7ip5-b]
>
> 2010-08-16 16:10:35,468 DEBUG [org.jboss.remoting.InvokerRegistry] removed SocketClientInvoker[11455a2, bisocket://x.x.x.x:657877203] from registry
>
> 2010-08-16 16:10:35,468 DEBUG [org.jboss.remoting.transport.socket.MicroSocketClientInvoker] SocketClientInvoker[11455a2, bisocket://x.x.x.x:657877203] disconnecting ...
>
> 2010-08-16 16:10:35,468 DEBUG [org.jboss.remoting.Client] Client[10883757:3m3b533o-il79jy-gcxc7el5-1-gcxc7fmx-4+3m3b533o-il79jy-gcxc7el5-1-gcxc7ip5-b] is disconnected
>
> 2010-08-16 16:10:35,468 DEBUG [org.jboss.remoting.callback.ServerInvokerCallbackHandler] ServerInvokerCallbackHandler[3m3b533o-il79jy-gcxc7el5-1-gcxc7fmx-4+3m3b533o-il79jy-gcxc7el5-1-gcxc7ip5-b] shut down
>
>
>
> 2010-08-16 16:10:36,171 DEBUG [org.jboss.jms.server.connectionmanager.SimpleConnectionManager] unregistered connection ConnectionEndpoint[w-ekj7cxcg-1-90c6cxcg-vn8ywe-o335b3m3] with remoting session ID ...-gcxc7fmx-4
>
> 2010-08-16 16:10:36,171 DEBUG [org.jboss.remoting.ConnectionNotifier] mailto:org.jboss.remoting.ConnectionNotifier@d77a85 org.jboss.remoting.ConnectionNotifier@d77a85 notified ConnectionManager[a16b7c] of connection lost to: 3m3b533o-il79jy-gcxc7el5-1-gcxc7fmx-4
>
>
>
> 2010-08-16 16:10:41,171 DEBUG [org.jboss.jms.client.remoting.ClientSocketWrapper] ServerSocketWrapper[Socket[addr=/x.x.x.x,port=60490,localport=4457].1cd25f]: os = mailto:java.net.SocketOutputStream@37633c java.net.SocketOutputStream@37633c
>
> 2010-08-16 16:10:41,171 DEBUG [org.jboss.jms.client.remoting.ClientSocketWrapper] ServerSocketWrapper[Socket[addr=/x.x.x.x,port=60490,localport=4457].1cd25f]: os = mailto:java.net.SocketOutputStream@542356 java.net.SocketOutputStream@542356
client side:
> INFO | jvm 1 | 2010/08/16 16:10:58 | an error occurred in HandleMessage: org.jboss.jms.exception.MessagingTransactionRolledBackException: Failed to invoke
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | org.jboss.jms.exception.MessagingTransactionRolledBackException: Failed to invoke
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.jms.tx.ResourceManager.commitLocal(ResourceManager.java:225)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.jms.client.container.SessionAspect.handleCommit(SessionAspect.java:582)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.aop.advice.org.jboss.jms.client.container.SessionAspect26.invoke(SessionAspect26.java)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.jms.client.delegate.ClientSessionDelegate$commit_8461082169793485964.invokeNext(ClientSessionDelegate$commit_8461082169793485964.java)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.jms.client.container.ClosedInterceptor.invoke(ClosedInterceptor.java:170)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.aop.advice.PerInstanceInterceptor.invoke(PerInstanceInterceptor.java:105)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.jms.client.delegate.ClientSessionDelegate$commit_8461082169793485964.invokeNext(ClientSessionDelegate$commit_8461082169793485964.java)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.jms.client.delegate.ClientSessionDelegate.commit(ClientSessionDelegate.java)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.jms.client.JBossSession.commit(JBossSession.java:164)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at com.jni.WorkerJni.handleMessage(WorkerJni.java:224)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at com.jni.WorkerJni.main(WorkerJni.java:164)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at java.lang.reflect.Method.invoke(Method.java:597)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.tanukisoftware.wrapper.WrapperSimpleApp.run(WrapperSimpleApp.java:240)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at java.lang.Thread.run(Thread.java:619)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | Caused by: org.jboss.jms.exception.MessagingJMSException: Failed to invoke
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.jms.client.delegate.DelegateSupport.handleThrowable(DelegateSupport.java:271)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.jms.client.delegate.DelegateSupport.doInvoke(DelegateSupport.java:205)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.jms.client.delegate.DelegateSupport.doInvoke(DelegateSupport.java:160)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.jms.client.delegate.ClientConnectionDelegate.org$jboss$jms$client$delegate$ClientConnectionDelegate$sendTransaction$aop(ClientConnectionDelegate.java:225)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.jms.client.delegate.ClientConnectionDelegate$sendTransaction_N3268650789275322226.invokeNext(ClientConnectionDelegate$sendTransaction_N3268650789275322226.java)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.jms.client.container.FailoverValveInterceptor.invoke(FailoverValveInterceptor.java:92)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.aop.advice.PerInstanceInterceptor.invoke(PerInstanceInterceptor.java:105)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.jms.client.delegate.ClientConnectionDelegate$sendTransaction_N3268650789275322226.invokeNext(ClientConnectionDelegate$sendTransaction_N3268650789275322226.java)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.jms.client.container.ClosedInterceptor.invoke(ClosedInterceptor.java:170)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.aop.advice.PerInstanceInterceptor.invoke(PerInstanceInterceptor.java:105)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.jms.client.delegate.ClientConnectionDelegate$sendTransaction_N3268650789275322226.invokeNext(ClientConnectionDelegate$sendTransaction_N3268650789275322226.java)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.jms.client.delegate.ClientConnectionDelegate.sendTransaction(ClientConnectionDelegate.java)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.jms.tx.ResourceManager.commitLocal(ResourceManager.java:206)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | ... 16 more
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | Caused by: java.lang.IllegalStateException: Cannot find object in dispatcher with id w-ekj7cxcg-1-90c6cxcg-vn8ywe-o335b3m3
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.jms.wireformat.ConnectionSendTransactionRequest.serverInvoke(ConnectionSendTransactionRequest.java:79)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.jms.server.remoting.JMSServerInvocationHandler.invoke(JMSServerInvocationHandler.java:157)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.remoting.ServerInvoker.invoke(ServerInvoker.java:862)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.remoting.transport.socket.ServerThread.processInvocation(ServerThread.java:611)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.remoting.transport.socket.ServerThread.dorun(ServerThread.java:423)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.remoting.transport.socket.ServerThread.run(ServerThread.java:176)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.remoting.MicroRemoteClientInvoker.invoke(MicroRemoteClientInvoker.java:182)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.remoting.Client.invoke(Client.java:1925)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.remoting.Client.invoke(Client.java:786)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.remoting.Client.invoke(Client.java:774)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | at org.jboss.jms.client.delegate.DelegateSupport.doInvoke(DelegateSupport.java:189)
>
> INFO | jvm 1 | 2010/08/16 16:10:58 | ... 27 more
thanks,
Noa
--------------------------------------------------------------
Reply to this message by going to Community
[http://community.jboss.org/message/557733#557733]
Start a new discussion in JBoss Messaging at Community
[http://community.jboss.org/choose-container!input.jspa?contentType=1&cont...]
16 years
[Javassist] - problem analyzing a stack frame
by Luca Ferrari
Luca Ferrari [http://community.jboss.org/people/cat4hire] created the discussion
"problem analyzing a stack frame"
To view the discussion, visit: http://community.jboss.org/message/557716#557716
--------------------------------------------------------------
Hi,
I'm trying to abalyze a simple method stack frame in order to get some informations about the status of local variables. I'm able to extract the name of the variables thru the code attribute and the constant pool as follows:
MethodInfo mInfo = method.getMethodInfo();
CodeAttribute ca = mInfo.getCodeAttribute();
LocalVariableAttribute lva = (LocalVariableAttribute) ca.getAttribute( LocalVariableAttribute.tag );
ConstPool constantPool = lva.getConstPool();
for( int i = 0; i< lva.tableLength(); i++ ){
String currentName = constantPool.getUtf8Info( lva.nameIndex(i) );
but what I'd like to have is the value also of such variables at the time I analyze the method on the stack. I don't understand how I can access the stack using the local variable table to get their value, anyone can help me?
--------------------------------------------------------------
Reply to this message by going to Community
[http://community.jboss.org/message/557716#557716]
Start a new discussion in Javassist at Community
[http://community.jboss.org/choose-container!input.jspa?contentType=1&cont...]
16 years
[JBoss Tools] - Create Eclipse Ecore (EMF) Models manually
by Andre Dietisheim
Andre Dietisheim [http://community.jboss.org/people/adietish] modified the document:
"Create Eclipse Ecore (EMF) Models manually"
To view the document, visit: http://community.jboss.org/docs/DOC-15705
--------------------------------------------------------------
h1. *Forewords*
EMF provides a runtime and tools that allow you to create ecore object models. The starting point is a model definition. It may be created out of a XML Schema (XSD), annotated java classes, etc. but you will mostly craft one by hand. This document attempts to describe the process involved in the later. It will show you the basic steps to create an ecore model implementation and give you some more advanced hints here and there.
There are a few tutorials available on http://www.eclipse.org/modeling/emf/docs/#tutorials eclipse.org, the best one (to my eyes's) the one provided by http://www.vogella.de/articles/EclipseEMF/article.html Lars Vogella.
h1. Get started, create an EMF Project
To get started, create an empty EMF project.
http://community.jboss.org/servlet/JiveServlet/showImage/102-15705-12-533... http://community.jboss.org/servlet/JiveServlet/downloadImage/102-15705-12...
You'll get a new project, that's set up to work with the EMF framework.
What's pops to your eyes is that there's a *model* directory in this project. That where the model definitions, the ecore files, are put (not a must but a standard so far).
h1. Create a Model Definition
Create a new ecore model file in this folder by selecting the folder and triggering the new ecore model wizard.
http://community.jboss.org/servlet/JiveServlet/showImage/102-15705-12-533... http://community.jboss.org/servlet/JiveServlet/downloadImage/102-15705-12...
h1. Create a Package
We created the empty ecore model so far, so the next step is to create a package for your model. You set its name, Ns Prefix and Ns URI.
The good practice (or at least what most modelers do) is to set them to:
* *name*: a simple term (not required to be unique)
* *Ns prefix*: ~shoretened 'java package' name (not required to be unique)
* *Ns URI*: some real (or bogus) unique URI where the scheme might be found.
h4. example
I have a plugin/module in cdo called *org.eclipse.emf.cdo.ui.defs*
The ecore model for it has the following definitions:
*name*: defs
*Ns prefix*: cdo.ui.defs
*Ns URI*: http://www.eclipse.org/emf/CDO/ui/defs/1.0.0 http://www.eclipse.org/emf/CDO/ui/defs/1.0.0
h1. Model Your Classes
You can now add classes to your package. There are different editors at hand that you may use to edit your ecore file. The most common one is the *Sample Ecore Model Editor* that is included in the Eclipse modeling edition. Alternatively you may also use text based editors like http://wiki.eclipse.org/Emfatic Emfatic or http://www.eclipse.org/Xtext/ Xtext. There are also graphical editors around like the* http://www.eclipse.org/modeling/emft/?project=ecoretools Ecore Diagram Editor or the eUML2 Editor.*
Ecore files define classes that will be generated in a later step. The generated java classes are not plain POJOs but extend http://download.eclipse.org/modeling/emf/emf/javadoc/2.5.0/index.html?org... EObject (you may tell the generator to create POJOs though). You may therefore only define elements that EObjects may have. There are *Classes, Attributes*, *References*, *Operations*, etc. A quick look at the http://download.eclipse.org/modeling/emf/emf/javadoc/2.5.0/org/eclipse/em... EObject class diagram may help you get in touch with the terms used in EMF.
EObjects offer various capabilities that are not (or at least at high cost) offered with plain POJOs. Extending EObjects in your model classes offers you all these capabilities free of charge:
* *serialization* (XML, XMI, binary, database based persistence, etc.)
* *change propagation*
* ** *validation*
* ** *object* *query*
* ** etc.
Furthermore the EMF ecosystem holds plenty of frameworks that extend it in various areas. Using EObject based POJOs allows you to take advantage of all these powerful frameworks.
h1. All Ways lead to Rome
*
*
There are usually several ways to get to the desired result (aka generated java code). The best way to find out about them is to get the† book or error and trial. A rule of thumb is to have all classes available in your model. This is evident for ecore classes. But if your ecore classes use references to plain java types (that are not part of your ecore model in the strict sense) you'll at least need to declare those java types in the ecore model. In other words, the ecore model needs to know about all types (ecore or plain java) that are part of your model.
h4. example1
Let's say that my modeled class CDOEditorDefs has a method execute() that throws an ExecutionException. I could add that method by hand but as a matter of taste I prefer to declare that method in my model.
My model does not know anything about this exception so far, so there's no way to get the correct signature generated out of the box . I'll therefore have to declare this exception in model. I create a DataType *ExecutionException*.
create an EDataType:
http://community.jboss.org/servlet/JiveServlet/showImage/4911/declare-dat... http://community.jboss.org/servlet/JiveServlet/downloadImage/4911/declare...
Give it an instance type name so it won't be generated but is referencable:
http://community.jboss.org/servlet/JiveServlet/showImage/4913/declare-exe... http://community.jboss.org/servlet/JiveServlet/downloadImage/4913/declare...
Set the execute method (operation) to throw the ExecutionException:
http://community.jboss.org/servlet/JiveServlet/showImage/4914/declare-thr... http://community.jboss.org/servlet/JiveServlet/downloadImage/4914/declare...
The generated method now throws the given Exception:
http://community.jboss.org/servlet/JiveServlet/showImage/4915/generated-t... http://community.jboss.org/servlet/JiveServlet/downloadImage/4915/generat...
h4. example2
A very common problem is to have modeled (ecore-) classes extend Java Interfaces. For instance this could be java.lang.Comparable
The best way to achieve that is to model a class Comparable. Do not model its operation as this is just a mirror of the real java interface in the ecore-world.
Interfaces are modeled as supertypes in ecore. You therefore cannot use EDataTypes here as they cannot be supertypes of ecore classes. Nevertheless you can achieve that in a slight different manner: You model a (real) ecore class, but you set its instance type name: *java.lang.Comparable*. You can now add the Comparable class to the super type of each ecore-class that shall implement Comparable. The generator will not generate an ecore class that's called Comparable but it will include java.lang.Comparable in the interface that your ecore-classes implement.
+*Not sure I follow this example and what we're trying to illustrate. Would example code help?*+
h1. Get prepared to generate code, create a Genmodel
This is mostly straight forward. Select the ecore file and create a genmodel for it. Select your ecore file and start a new *EMF Generator Model* wizard. The wizard will allow you to create a so called Generator Model that holds all settings which are important to the code generation process.
http://community.jboss.org/servlet/JiveServlet/showImage/102-15705-12-533... http://community.jboss.org/servlet/JiveServlet/downloadImage/102-15705-12...
There are 2 settings that might be of interest to you:
'*All*' (property group when the package is selected):
- *Base Package*: the base package all ecore classes get generated to
- *Prefix*: Prefix that the factory- and package-class get
http://community.jboss.org/servlet/JiveServlet/showImage/102-15705-12-533... http://community.jboss.org/servlet/JiveServlet/downloadImage/102-15705-12...
example (still using the cdo.ui.defs example):
*Base Package*: org.eclipse.emf.cdo.ui
*Prefix*: CDOUIDefs
Package-class gets CDOUIDefsPackage, Factory gets CDOUIDefsFactory, etc. All classes get generated to the package org.eclipse.emf.cdo.ui
Further modifications you might be interested in are the suffixes of the sub-packages (the defaults creates an 'impl' package where it puts all implementation classes). It can be modified by selecting the '*Package Suffixes*' and choosing the properties '*Implementation*' and '*Interfaces*'.
The naming of the implementation- and interface-classes may be changed, too. You find those settings if you select the root-node of the tree in the genmodel-editor and choose the '*Model*' property group. You'll find 'Class Name Pattern' and 'Interface Name Pattern' among the available properties. The explanations for the values show up in the statusbar (default is '*{0}impl*' and '*{0}*').
http://community.jboss.org/servlet/JiveServlet/showImage/102-15697-11-484... http://community.jboss.org/servlet/JiveServlet/downloadImage/102-15697-11...
Once you're done defining your generator model, you simply need to generate the implementation classes. Select the package you want to generate, right click and select the implementation you want to create. You may choose among the models, the editor, the tests.
http://community.jboss.org/servlet/JiveServlet/showImage/102-15697-11-485... http://community.jboss.org/servlet/JiveServlet/downloadImage/102-15697-11...
h1. Modify the Generated Classes
Ecore is built to be modified, the basic usage-pattern is to code and generate hand-in-hand. To tell the generator not to override your modifications you need to set the javadoc-annotation to anything different than '@generated'. Good practice says that you should set it to '@generated NOT'. Good practice also tells you to annotate any manually added method by '@ADDED', but its optional though.
There is another handy that allows you to modify and get the generated code. If you want to have your code instead of the generated one, you just annotate accordingly and the generator will preserve your code. If you want the generated code, too, you'd need to create a method that has the original name + a suffix 'Gen'
example:
/**
*
* @generated NOT
*/
public void setName(String name) {
YOUR OWN CODE
}
/**
*
* @generated
*/
public void setNameGen(String name) {
GENERATOR provides the generated code in here
}
After making your modifications, you simply need to re-generate the ecore classes. (+*How?*+)
--------------------------------------------------------------
Comment by going to Community
[http://community.jboss.org/docs/DOC-15705]
Create a new document in JBoss Tools at Community
[http://community.jboss.org/choose-container!input.jspa?contentType=102&co...]
16 years
