Sorry for the convoluted post. To state it succinctly. Can I use vysper to
On Sat, May 11, 2013 at 3:50 PM, Bernd Fondermann < [email protected]> wrote: > I'd suggest you wait between > c.sendMessage("THIS IS MY TEST MESSAGE",talkTo); > and > c.disconnect(); > for example by adding a Thread.sleep(10*1000); > > > > On Fri, May 10, 2013 at 9:48 PM, Frank Arico <[email protected]> > wrote: > > > I am trying to intercept XMPP messages and do some non XMPP event > handling > > on the message content. The actual XMPP client will be sending messages > > to another applications's XMPP server but will also send to my > instance > > of vysper for event processing. I do not want to set up a client session > > on my server but just want to intercept and do some processing on the > > message content. Is this possible? ( Apologies in advance, I am new to > > XMPP.) > > This processing would in no way participate in the XMPPconversion > > occurring on the other server. The use case is to intercept > > XMPP traffic and use a Stanza filter to only receive the message , do > some > > processing on the message and not send out the Message. The other > > XMPPserver is handling all the client/server interaction. > > > > Here the filter I am using to intercept the XMPP message. I adapted it > > from the Standard Logging filter. > > > > public class HomeSecurityStanzaFilter extends IoFilterAdapter { > > > > final Logger serverLogger = LoggerFactory.getLogger("stanza.server"); > > > > > > final Logger clientLogger = LoggerFactory.getLogger("stanza.client"); > > > > > > > > public void messageReceived(NextFilter nextFilter, IoSession session, > > Object message) throws Exception { > > if (message instanceof XMLElement) { > > XMLElement element = (XMLElement) message; > > > > > > > > boolean openElement = true; > > > > > > boolean closeElement = true; > > > > > > // this is somewhat of a hack, can we detect opening and > > closing elements only cleaner? > > if (element.getName().equals("stream")) { > > if (element.getAttributes().size() > 0) { > > // is stream element, and with attributes, should be > > opening tag > > closeElement = false; > > > > > > } else { > > // is stream element, without attributes, should be > > closing tag > > openElement = false; > > > > > > } > > } > > > > String xml = toXml(element, openElement, closeElement); > > > > > > clientLogger.debug("< " + xml); > > > > > > > > } > > > > nextFilter.messageReceived(session, message); > > > > > > } > > > > public void messageSent(NextFilter nextFilter, IoSession session, > > WriteRequest request) throws Exception { > > > > Object message = request.getMessage(); > > > > > > if (message instanceof StanzaWriteInfo) { > > StanzaWriteInfo stanzaWriteInfo = (StanzaWriteInfo) message; > > > > > > > > String xml = toXml(stanzaWriteInfo.getStanza(), stanzaWriteInfo. > > isWriteOpeningElement(), > > stanzaWriteInfo.isWriteClosingElement()); > > > > > > serverLogger.debug("> " + xml); > > > > > > } > > nextFilter.messageSent(session, request); > > > > > > } > > > > private String toXml(XMLElement element, boolean openElement, boolean > > closeElement) { > > Renderer renderer = new Renderer(element); > > > > > > > > StringBuffer xml = new StringBuffer(); > > > > > > if (openElement) { > > xml.append(renderer.getOpeningElement()); > > > > > > } > > > > ... > > ... > > } > > > > Here's my client test program using Smack API > > > > import java.util.*; > > import java.io.*; > > > > import org.jivesoftware.smack.Chat; > > import org.jivesoftware.smack.ConnectionConfiguration; > > import org.jivesoftware.smack.MessageListener; > > import org.jivesoftware.smack.Roster; > > import org.jivesoftware.smack.RosterEntry; > > import org.jivesoftware.smack.XMPPConnection; > > import org.jivesoftware.smack.XMPPException; > > import org.jivesoftware.smack.packet.Message; > > > > public class SendMessage implements MessageListener{ > > > > XMPPConnection connection; > > > > public void login(String userName, String password) throws > > XMPPException > > { > > ConnectionConfiguration config = new > > ConnectionConfiguration("localhost",5222, > > "Work"); > > connection = new XMPPConnection(config); > > > > connection.connect(); > > connection.login(userName, password); > > } > > > > public void sendMessage(String message, String to) throws > XMPPException > > { > > Chat chat = connection.getChatManager().createChat(to, this); > > chat.sendMessage(message); > > } > > > > > > public void disconnect() > > { > > connection.disconnect(); > > } > > > > > > public static void main(String args[]) throws XMPPException, > > IOException > > { > > // declare variables > > SendMessage c = new SendMessage(); > > BufferedReader br = new BufferedReader(new InputStreamReader > > (System.in)); > > String msg; > > > > > > // turn on the enhanced debugger > > XMPPConnection.DEBUG_ENABLED = true; > > > > > > // Enter your login information here > > c.login("user1", "password"); > > > > String talkTo = "[email protected]"; > > System.out.println("All messages will be sent to " + talkTo); > > > > c.sendMessage("THIS IS MY TEST MESSAGE",talkTo); > > > > c.disconnect(); > > System.exit(0); > > } > > > > } > > > > When I start my copy of vysper and then run my client test program I get > > the following stack trace > > > > DEBUG [2013 May 10 15:31:36.308] (VysperMain.java:main:51) - > > HSvysperstarting > > > > INFO [2013 May 10 15:31:36.334] > (OpenStorageProviderRegistry.java:add:81) > > - could not load storage provider class org.apache.vysper.xmpp > > .modules.extension.xep0060_pubsub.storageprovider. > > LeafNodeInMemoryStorageProvider > > > > INFO [2013 May 10 15:31:36.335] > (OpenStorageProviderRegistry.java:add:81) > > - could not load storage provider class org.apache.vysper.xmpp > > .modules.extension.xep0060_pubsub.storageprovider. > > CollectionNodeInMemoryStorageProvider > > > > INFO [2013 May 10 15:31:36.689] (DefaultServerRuntimeContext.java: > > setStorageProviderRegistry:267) - replacing the storage provider registry > > with org.apache.vysper.storage.inmemory.MemoryStorageProviderRegistry > > > > INFO [2013 May 10 15:31:36.726] (DefaultServerRuntimeContext.java: > > addModuleInternal:316) - adding module... servicediscovery (1.0beta) > > > > INFO [2013 May 10 15:31:36.737] (DefaultServerRuntimeContext.java: > > addModuleInternal:316) - adding module... roster (1.0beta) > > > > DEBUG [2013 May 10 15:31:36.811] (VysperMain.java:main:86) - > > HSvysperserver is running... > > > > INFO [2013 May 10 15:31:36.813] (DefaultServerRuntimeContext.java: > > addModuleInternal:316) - adding module... XEP-0092 Software Version (1.0) > > > > INFO [2013 May 10 15:31:36.818] (DefaultServerRuntimeContext.java: > > addModuleInternal:316) - adding module... XEP-0202 Entity Time (1.0) > > > > INFO [2013 May 10 15:31:36.825] (DefaultServerRuntimeContext.java: > > addModuleInternal:316) - adding module... XEP-0054 Vcard-temp (1.0) > > > > ERROR [2013 May 10 15:31:36.825] (VcardTempModule.java:initialize:55) - > no > > VcardTempPersistenceManager found > > > > INFO [2013 May 10 15:31:36.826] (DefaultServerRuntimeContext.java: > > addModuleInternal:316) - adding module... XEP-0199 XMPP Ping (2.0) > > > > INFO [2013 May 10 15:31:36.840] (DefaultServerRuntimeContext.java: > > addModuleInternal:316) - adding module... XEP-0049 Private Data (1.2) > > > > ERROR [2013 May 10 15:31:36.841] (PrivateDataModule.java:initialize:55) - > > no PrivateDataPersistenceManager found > > > > INFO [2013 May 10 15:31:36.842] (DefaultServerRuntimeContext.java: > > addModuleInternal:316) - adding module... XEP-0077 In-Band Registration > > (2.3) > > > > INFO [2013 May 10 15:31:36.844] (DefaultServerRuntimeContext.java: > > addModuleInternal:316) - adding module... XEP-0050 Ad-hoc Commands (1.2) > > > > INFO [2013 May 10 15:31:36.850] (DefaultServerRuntimeContext.java: > > addModuleInternal:316) - adding module... XEP-0133 Service Administration > > (1.1) > > > > DEBUG [2013 May 10 15:31:40.913] (SessionStateHolder.java:setState:43) - > > session state changed to = INITIATED > > > > INFO [2013 May 10 15:31:40.916] (XmppIoHandlerAdapter.java:sessionOpened > > :110) - new session from /127.0.0.1:61499 has been opened > > > > DEBUG [2013 May 10 15:31:42.092] > (ProtocolCodecFilter.java:messageReceived > > :220) - Processing a MESSAGE_RECEIVED for session 1 > > > > DEBUG [2013 May 10 15:31:42.250] > (XMPPContentHandler.java:emitStanza:124) - > > Decoder writing stanza: <stream:stream xmlns:stream="http://etherx. > > jabber.org/streams" to="Work" version="1.0"></stream:stream> > > > > DEBUG [2013 May 10 15:31:42.251] > (StanzaLoggingFilter.java:messageReceived > > :61) - < <stream:stream xmlns:stream="http://etherx.jabber.org/streams"; > > to="Work" version="1.0"> > > > > DEBUG [2013 May 10 15:31:42.251] (HomeSecurityStanzaFilter.java: > > messageReceived:56) - < <stream:stream xmlns:stream="http://etherx. > > jabber.org/streams" to="Work" version="1.0"> > > > > DEBUG [2013 May 10 15:31:42.258] (SessionStateHolder.java:setState:43) - > > session state changed to = STARTED > > > > DEBUG [2013 May 10 15:31:42.272] > (StanzaLoggingFilter.java:messageSent:79) > > - > <stream:stream xmlns="jabber:client" xmlns:stream="http://etherx. > > jabber.org/streams" from="hsvysper.org" version="1.0" > > id="d81fde63f689463a8e138031d0713139"><stream:features > > xmlns:stream="http:// > > etherx.jabber.org/streams"><starttls > > xmlns="urn:ietf:params:xml:ns:xmpp-tls > > "><required></required></starttls><register xmlns=" > > http://jabber.org/features/iq-register";></register></stream:features> > > > > DEBUG [2013 May 10 15:31:42.273] > > (HomeSecurityStanzaFilter.java:messageSent: > > 72) - > <stream:stream xmlns="jabber:client" xmlns:stream="http://etherx > . > > jabber.org/streams" from="hsvysper.org" version="1.0" > > id="d81fde63f689463a8e138031d0713139"><stream:features > > xmlns:stream="http:// > > etherx.jabber.org/streams"><starttls > > xmlns="urn:ietf:params:xml:ns:xmpp-tls > > "><required></required></starttls><register xmlns=" > > http://jabber.org/features/iq-register";></register></stream:features> > > > > DEBUG [2013 May 10 15:31:42.276] > (ProtocolCodecFilter.java:messageReceived > > :220) - Processing a MESSAGE_RECEIVED for session 1 > > > > DEBUG [2013 May 10 15:31:42.277] > (XMPPContentHandler.java:emitStanza:124) - > > Decoder writing stanza: <starttls > > xmlns="urn:ietf:params:xml:ns:xmpp-tls"></ > > starttls> > > > > DEBUG [2013 May 10 15:31:42.277] > (StanzaLoggingFilter.java:messageReceived > > :61) - < <starttls xmlns="urn:ietf:params:xml:ns:xmpp-tls"></starttls> > > > > DEBUG [2013 May 10 15:31:42.277] (HomeSecurityStanzaFilter.java: > > messageReceived:56) - < <starttls > > xmlns="urn:ietf:params:xml:ns:xmpp-tls"></ > > starttls> > > > > DEBUG [2013 May 10 15:31:42.278] (SessionStateHolder.java:setState:43) - > > session state changed to = ENCRYPTION_STARTED > > > > DEBUG [2013 May 10 15:31:42.280] (SslFilter.java:onPreAdd:410) - Adding > the > > SSL Filter sslFilter to the chain > > > > DEBUG [2013 May 10 15:31:42.282] (SslHandler.java:init:137) - Session > > Server[1](no sslEngine) Initializing the SSL Handler > > > > DEBUG [2013 May 10 15:31:42.441] (SslHandler.java:init:188) - Session > > Server[1](no sslEngine) SSL Handler Initialization done. > > > > DEBUG [2013 May 10 15:31:42.441] (SslFilter.java:initiateHandshake:664) - > > Session Server[1](ssl...) : Starting the first handshake > > > > DEBUG [2013 May 10 15:31:42.441] (SslHandler.java:handshake:546) - > Session > > Server[1](ssl...) processing the NEED_UNWRAP state > > > > DEBUG [2013 May 10 15:31:42.443] (SslFilter.java:filterWrite:581) - > Session > > Server[1](ssl...): Writing Message : WriteRequest: HeapBuffer[pos=0 > lim=59 > > cap=64: 3C 70 72 6F 63 65 65 64 20 78 6D 6C 6E 73 3D 22...] > > > > DEBUG [2013 May 10 15:31:42.445] (SslFilter.java:filterWrite:581) - > Session > > Server[1](ssl...): Writing Message : MessageWriteRequest, parent : WR > > WrapperWriteRequest: [ prolog=false, open=true, close=true, content=true, > > stanza=[proceed] > > > > DEBUG [2013 May 10 15:31:42.772] (SslFilter.java:messageReceived:460) - > > Session Server[1](ssl...): Message received : HeapBuffer[pos=0 lim=112 > > cap=1024: 80 6E 01 03 01 00 45 00 00 00 20 00 00 04 01 00...] > > > > DEBUG [2013 May 10 15:31:42.773] (SslHandler.java:messageReceived:335) - > > Session Server[1](ssl...) Processing the received message > > > > DEBUG [2013 May 10 15:31:42.773] (SslHandler.java:handshake:546) - > Session > > Server[1](ssl...) processing the NEED_UNWRAP state > > > > DEBUG [2013 May 10 15:31:42.774] (SslHandler.java:handshake:538) - > Session > > Server[1](ssl...) processing the NEED_TASK state > > > > DEBUG [2013 May 10 15:31:42.777] (SslHandler.java:handshake:561) - > Session > > Server[1](ssl...) processing the NEED_WRAP state > > > > DEBUG [2013 May 10 15:31:42.777] (SslFilter.java:filterWrite:581) - > Session > > Server[1](ssl...): Writing Message : WriteRequest: HeapBuffer[pos=0 > lim=560 > > cap=1041: 16 03 01 02 2B 02 00 00 4D 03 01 51 8D 4B 1E ED...] > > > > DEBUG [2013 May 10 15:31:42.778] (SslHandler.java:handshake:546) - > Session > > Server[1](ssl...) processing the NEED_UNWRAP state > > > > DEBUG [2013 May 10 15:31:42.778] (SslFilter.java:handleSslData:706) - > > Session Server[1](ssl...): Processing the SSL Data > > > > DEBUG [2013 May 10 15:31:42.786] (SslFilter.java:messageReceived:460) - > > Session Server[1](ssl...): Message received : HeapBuffer[pos=0 lim=75 > > cap=1024: 16 03 01 00 46 10 00 00 42 00 40 56 AE 13 A9 64...] > > > > DEBUG [2013 May 10 15:31:42.786] (SslHandler.java:messageReceived:335) - > > Session Server[1](ssl...) Processing the received message > > > > DEBUG [2013 May 10 15:31:42.786] (SslHandler.java:handshake:546) - > Session > > Server[1](ssl...) processing the NEED_UNWRAP state > > > > DEBUG [2013 May 10 15:31:42.786] (SslHandler.java:handshake:538) - > Session > > Server[1](ssl...) processing the NEED_TASK state > > > > DEBUG [2013 May 10 15:31:42.802] (SslHandler.java:handshake:546) - > Session > > Server[1](ssl...) processing the NEED_UNWRAP state > > > > DEBUG [2013 May 10 15:31:42.803] (SslFilter.java:handleSslData:706) - > > Session Server[1](ssl...): Processing the SSL Data > > > > DEBUG [2013 May 10 15:31:42.803] (SslFilter.java:messageReceived:460) - > > Session Server[1](ssl...): Message received : HeapBuffer[pos=0 lim=6 > > cap=512: 14 03 01 00 01 01] > > > > DEBUG [2013 May 10 15:31:42.803] (SslHandler.java:messageReceived:335) - > > Session Server[1](ssl...) Processing the received message > > > > DEBUG [2013 May 10 15:31:42.804] (SslHandler.java:handshake:546) - > Session > > Server[1](ssl...) processing the NEED_UNWRAP state > > > > DEBUG [2013 May 10 15:31:42.988] (SslFilter.java:handleSslData:706) - > > Session Server[1](ssl...): Processing the SSL Data > > > > DEBUG [2013 May 10 15:31:42.989] (SslFilter.java:messageReceived:460) - > > Session Server[1](ssl...): Message received : HeapBuffer[pos=0 lim=37 > > cap=512: 16 03 01 00 20 39 DE 97 6B B8 D5 13 8D B9 4B 78...] > > > > DEBUG [2013 May 10 15:31:42.989] (SslHandler.java:messageReceived:335) - > > Session Server[1](ssl...) Processing the received message > > > > DEBUG [2013 May 10 15:31:42.989] (SslHandler.java:handshake:546) - > Session > > Server[1](ssl...) processing the NEED_UNWRAP state > > > > DEBUG [2013 May 10 15:31:42.990] (SslHandler.java:handshake:561) - > Session > > Server[1](ssl...) processing the NEED_WRAP state > > > > DEBUG [2013 May 10 15:31:42.990] (SslFilter.java:filterWrite:581) - > Session > > Server[1](ssl...): Writing Message : WriteRequest: HeapBuffer[pos=0 lim=6 > > cap=8: 14 03 01 00 01 01] > > > > DEBUG [2013 May 10 15:31:42.991] (SslHandler.java:handshake:561) - > Session > > Server[1](ssl...) processing the NEED_WRAP state > > > > DEBUG [2013 May 10 15:31:42.991] (SslFilter.java:filterWrite:581) - > Session > > Server[1](ssl...): Writing Message : WriteRequest: HeapBuffer[pos=0 > lim=37 > > cap=65: 16 03 01 00 20 90 65 38 FC 3B 9C 4C 1F C1 95 32...] > > > > DEBUG [2013 May 10 15:31:42.991] (SslHandler.java:handshake:513) - > Session > > Server[1](ssl...) processing the FINISHED state > > > > DEBUG [2013 May 10 15:31:42.991] (SslHandler.java:handshake:528) - > Session > > Server[1](SSL) is now secured > > > > DEBUG [2013 May 10 15:31:42.991] (SslHandler.java:handshake:513) - > Session > > Server[1](SSL) processing the FINISHED state > > > > DEBUG [2013 May 10 15:31:42.991] (SslHandler.java:handshake:528) - > Session > > Server[1](SSL) is now secured > > > > DEBUG [2013 May 10 15:31:42.992] (SslFilter.java:handleSslData:706) - > > Session Server[1](SSL): Processing the SSL Data > > > > DEBUG [2013 May 10 15:31:42.992] (SslFilter.java:filterWrite:581) - > Session > > Server[1](SSL): Writing Message : MessageWriteRequest, parent : WR > > WrapperWriteRequest: [ prolog=false, open=true, close=true, content=true, > > stanza=[proceed] > > > > DEBUG [2013 May 10 15:31:42.992] > (ProtocolCodecFilter.java:messageReceived > > :220) - Processing a MESSAGE_RECEIVED for session 1 > > > > DEBUG [2013 May 10 15:31:42.993] (SessionStateHolder.java:setState:43) - > > session state changed to = ENCRYPTED > > > > DEBUG [2013 May 10 15:31:42.994] > (StanzaLoggingFilter.java:messageSent:79) > > - > <proceed xmlns="urn:ietf:params:xml:ns:xmpp-tls"></proceed> > > > > DEBUG [2013 May 10 15:31:42.994] > > (HomeSecurityStanzaFilter.java:messageSent: > > 72) - > <proceed xmlns="urn:ietf:params:xml:ns:xmpp-tls"></proceed> > > > > DEBUG [2013 May 10 15:31:42.995] (SslFilter.java:messageReceived:460) - > > Session Server[1](SSL): Message received : HeapBuffer[pos=0 lim=138 > > cap=256: 17 03 01 00 85 85 6E 34 E2 F6 17 97 3D BF 1C 31...] > > > > DEBUG [2013 May 10 15:31:42.995] (SslHandler.java:messageReceived:335) - > > Session Server[1](SSL) Processing the received message > > > > DEBUG [2013 May 10 15:31:42.996] (SslFilter.java:handleSslData:706) - > > Session Server[1](SSL): Processing the SSL Data > > > > DEBUG [2013 May 10 15:31:42.996] > (ProtocolCodecFilter.java:messageReceived > > :220) - Processing a MESSAGE_RECEIVED for session 1 > > > > DEBUG [2013 May 10 15:31:42.997] > (XMPPContentHandler.java:emitStanza:124) - > > Decoder writing stanza: <stream:stream xmlns:stream="http://etherx. > > jabber.org/streams" to="hsvysper.org" version="1.0"></stream:stream> > > > > DEBUG [2013 May 10 15:31:42.998] > (StanzaLoggingFilter.java:messageReceived > > :61) - < <stream:stream xmlns:stream="http://etherx.jabber.org/streams"; > > to=" > > hsvysper.org" version="1.0"> > > > > DEBUG [2013 May 10 15:31:42.999] (HomeSecurityStanzaFilter.java: > > messageReceived:56) - < <stream:stream xmlns:stream="http://etherx. > > jabber.org/streams" to="hsvysper.org" version="1.0"> > > > > DEBUG [2013 May 10 15:31:43.000] (SslFilter.java:filterWrite:581) - > Session > > Server[1](SSL): Writing Message : WriteRequest: HeapBuffer[pos=0 lim=372 > > cap=512: 3C 3F 78 6D 6C 20 76 65 72 73 69 6F 6E 3D 22 31...] > > > > DEBUG [2013 May 10 15:31:43.001] (SslFilter.java:filterWrite:581) - > Session > > Server[1](SSL): Writing Message : MessageWriteRequest, parent : WR > > WrapperWriteRequest: [ prolog=true, open=true, close=false, content=true, > > stanza=[stream.features.mechanisms[PLAIN]] > > > > DEBUG [2013 May 10 15:31:43.002] > (StanzaLoggingFilter.java:messageSent:79) > > - > <stream:stream xmlns="jabber:client" xmlns:stream="http://etherx. > > jabber.org/streams" from="hsvysper.org" version="1.0" > > id="d81fde63f689463a8e138031d0713139"><stream:features > > xmlns:stream="http:// > > etherx.jabber.org/streams"><mechanisms > xmlns="urn:ietf:params:xml:ns:xmpp- > > sasl"><mechanism>PLAIN</mechanism></mechanisms></stream:features> > > > > DEBUG [2013 May 10 15:31:43.003] > > (HomeSecurityStanzaFilter.java:messageSent: > > 72) - > <stream:stream xmlns="jabber:client" xmlns:stream="http://etherx > . > > jabber.org/streams" from="hsvysper.org" version="1.0" > > id="d81fde63f689463a8e138031d0713139"><stream:features > > xmlns:stream="http:// > > etherx.jabber.org/streams"><mechanisms > xmlns="urn:ietf:params:xml:ns:xmpp- > > sasl"><mechanism>PLAIN</mechanism></mechanisms></stream:features> > > > > DEBUG [2013 May 10 15:31:43.041] (SslFilter.java:messageReceived:460) - > > Session Server[1](SSL): Message received : HeapBuffer[pos=0 lim=121 > > cap=256: 17 03 01 00 74 5F 48 29 9E 01 73 DC B4 E5 E1 5A...] > > > > DEBUG [2013 May 10 15:31:43.041] (SslHandler.java:messageReceived:335) - > > Session Server[1](SSL) Processing the received message > > > > DEBUG [2013 May 10 15:31:43.042] (SslFilter.java:handleSslData:706) - > > Session Server[1](SSL): Processing the SSL Data > > > > DEBUG [2013 May 10 15:31:43.042] > (ProtocolCodecFilter.java:messageReceived > > :220) - Processing a MESSAGE_RECEIVED for session 1 > > > > DEBUG [2013 May 10 15:31:43.043] > (XMPPContentHandler.java:emitStanza:124) - > > Decoder writing stanza: <auth xmlns="urn:ietf:params:xml:ns:xmpp-sasl" > > mechanism="PLAIN">dXNlcjEAdXNlcjEAcGFzc3dvcmQ=</auth> > > > > DEBUG [2013 May 10 15:31:43.043] > (StanzaLoggingFilter.java:messageReceived > > :61) - < <auth xmlns="urn:ietf:params:xml:ns:xmpp-sasl" > > mechanism="PLAIN">dXNlcjEAdXNlcjEAcGFzc3dvcmQ=</auth> > > > > DEBUG [2013 May 10 15:31:43.043] (HomeSecurityStanzaFilter.java: > > messageReceived:56) - < <auth xmlns="urn:ietf:params:xml:ns:xmpp-sasl" > > mechanism="PLAIN">dXNlcjEAdXNlcjEAcGFzc3dvcmQ=</auth> > > > > DEBUG [2013 May 10 15:31:43.048] (SessionStateHolder.java:setState:43) - > > session state changed to = AUTHENTICATED > > > > DEBUG [2013 May 10 15:31:43.049] (SslFilter.java:filterWrite:581) - > Session > > Server[1](SSL): Writing Message : WriteRequest: HeapBuffer[pos=0 lim=60 > > cap=64: 3C 73 75 63 63 65 73 73 20 78 6D 6C 6E 73 3D 22...] > > > > DEBUG [2013 May 10 15:31:43.049] (SslFilter.java:filterWrite:581) - > Session > > Server[1](SSL): Writing Message : MessageWriteRequest, parent : WR > > WrapperWriteRequest: [ prolog=false, open=true, close=true, content=true, > > stanza=[success] > > > > DEBUG [2013 May 10 15:31:43.050] > (StanzaLoggingFilter.java:messageSent:79) > > - > <success xmlns="urn:ietf:params:xml:ns:xmpp-sasl"></success> > > > > DEBUG [2013 May 10 15:31:43.050] > > (HomeSecurityStanzaFilter.java:messageSent: > > 72) - > <success xmlns="urn:ietf:params:xml:ns:xmpp-sasl"></success> > > > > DEBUG [2013 May 10 15:31:43.052] (SslFilter.java:messageReceived:460) - > > Session Server[1](SSL): Message received : HeapBuffer[pos=0 lim=138 > > cap=256: 17 03 01 00 85 C2 DF 03 22 4B B4 8B 73 7C 63 BF...] > > > > DEBUG [2013 May 10 15:31:43.052] (SslHandler.java:messageReceived:335) - > > Session Server[1](SSL) Processing the received message > > > > DEBUG [2013 May 10 15:31:43.052] (SslFilter.java:handleSslData:706) - > > Session Server[1](SSL): Processing the SSL Data > > > > DEBUG [2013 May 10 15:31:43.053] > (ProtocolCodecFilter.java:messageReceived > > :220) - Processing a MESSAGE_RECEIVED for session 1 > > > > DEBUG [2013 May 10 15:31:43.054] > (XMPPContentHandler.java:emitStanza:124) - > > Decoder writing stanza: <stream:stream xmlns:stream="http://etherx. > > jabber.org/streams" to="hsvysper.org" version="1.0"></stream:stream> > > > > DEBUG [2013 May 10 15:31:43.055] > (StanzaLoggingFilter.java:messageReceived > > :61) - < <stream:stream xmlns:stream="http://etherx.jabber.org/streams"; > > to=" > > hsvysper.org" version="1.0"> > > > > DEBUG [2013 May 10 15:31:43.055] (HomeSecurityStanzaFilter.java: > > messageReceived:56) - < <stream:stream xmlns:stream="http://etherx. > > jabber.org/streams" to="hsvysper.org" version="1.0"> > > > > DEBUG [2013 May 10 15:31:43.057] (SslFilter.java:filterWrite:581) - > Session > > Server[1](SSL): Writing Message : WriteRequest: HeapBuffer[pos=0 lim=437 > > cap=512: 3C 3F 78 6D 6C 20 76 65 72 73 69 6F 6E 3D 22 31...] > > > > DEBUG [2013 May 10 15:31:43.058] (SslFilter.java:filterWrite:581) - > Session > > Server[1](SSL): Writing Message : MessageWriteRequest, parent : WR > > WrapperWriteRequest: [ prolog=true, open=true, close=false, content=true, > > stanza=[stream] > > > > DEBUG [2013 May 10 15:31:43.059] > (StanzaLoggingFilter.java:messageSent:79) > > - > <stream:stream xmlns="jabber:client" xmlns:stream="http://etherx. > > jabber.org/streams" from="hsvysper.org" version="1.0" > > id="d81fde63f689463a8e138031d0713139"><stream:features > > xmlns:stream="http:// > > etherx.jabber.org/streams"><bind > > > > > xmlns="urn:ietf:params:xml:ns:xmpp-bind"><required></required></bind><session > > xmlns="urn:ietf:params:xml:ns:xmpp > > -session"><required></required></session></stream:features> > > > > DEBUG [2013 May 10 15:31:43.060] > > (HomeSecurityStanzaFilter.java:messageSent: > > 72) - > <stream:stream xmlns="jabber:client" xmlns:stream="http://etherx > . > > jabber.org/streams" from="hsvysper.org" version="1.0" > > id="d81fde63f689463a8e138031d0713139"><stream:features > > xmlns:stream="http:// > > etherx.jabber.org/streams"><bind > > > > > xmlns="urn:ietf:params:xml:ns:xmpp-bind"><required></required></bind><session > > xmlns="urn:ietf:params:xml:ns:xmpp > > -session"><required></required></session></stream:features> > > > > DEBUG [2013 May 10 15:31:43.062] (SslFilter.java:messageReceived:460) - > > Session Server[1](SSL): Message received : HeapBuffer[pos=0 lim=134 > > cap=256: 17 03 01 00 81 D0 8D C4 43 9D DA 8F EA 69 52 5D...] > > > > DEBUG [2013 May 10 15:31:43.062] (SslHandler.java:messageReceived:335) - > > Session Server[1](SSL) Processing the received message > > > > DEBUG [2013 May 10 15:31:43.063] (SslFilter.java:handleSslData:706) - > > Session Server[1](SSL): Processing the SSL Data > > > > DEBUG [2013 May 10 15:31:43.063] > (ProtocolCodecFilter.java:messageReceived > > :220) - Processing a MESSAGE_RECEIVED for session 1 > > > > DEBUG [2013 May 10 15:31:43.065] > (XMPPContentHandler.java:emitStanza:124) - > > Decoder writing stanza: <iq xmlns="jabber:client" id="5aOWt-0" > > type="set"><bind xmlns="urn:ietf:params:xml:ns:xmpp > > -bind"><resource>Smack</resource></bind></iq> > > > > DEBUG [2013 May 10 15:31:43.065] > (StanzaLoggingFilter.java:messageReceived > > :61) - < <iq xmlns="jabber:client" id="5aOWt-0" type="set"><bind > > xmlns="urn: > > ietf:params:xml:ns:xmpp-bind"><resource>Smack</resource></bind></iq> > > > > DEBUG [2013 May 10 15:31:43.066] (HomeSecurityStanzaFilter.java: > > messageReceived:56) - < <iq xmlns="jabber:client" id="5aOWt-0" > > type="set"><bind xmlns="urn:ietf:params:xml:ns:xmpp > > -bind"><resource>Smack</resource></bind></iq> > > > > INFO [2013 May 10 15:31:43.070] (ResourceRegistry.java:bindSession:112) > - > > added resource no. 1 to entity [email protected] <- > > 7f19e37e0555455ab4fa3e51ef3e9f2b > > > > INFO [2013 May 10 15:31:43.070] (ResourceRegistry.java:bindSession:121) > - > > added resource no. 1 to session d81fde63f689463a8e138031d0713139 <- > > 7f19e37e0555455ab4fa3e51ef3e9f2b > > > > DEBUG [2013 May 10 15:31:43.154] (SslFilter.java:filterWrite:581) - > Session > > Server[1](SSL): Writing Message : WriteRequest: HeapBuffer[pos=0 lim=174 > > cap=256: 3C 69 71 20 78 6D 6C 6E 73 3D 22 6A 61 62 62 65...] > > > > DEBUG [2013 May 10 15:31:43.155] (SslFilter.java:filterWrite:581) - > Session > > Server[1](SSL): Writing Message : MessageWriteRequest, parent : WR > > WrapperWriteRequest: [ prolog=false, open=true, close=true, content=true, > > stanza=[iq.id > ='5aOWt-0'.type='result'.bind.xmlns='urn:ietf:params:xml:ns: > > xmpp-bind'] > > > > DEBUG [2013 May 10 15:31:43.155] > (StanzaLoggingFilter.java:messageSent:79) > > - > <iq xmlns="jabber:client" type="result" id="5aOWt-0"><bind > xmlns="urn: > > ietf:params:xml:ns:xmpp-bind"><jid>user1@hsvysper > > .org/7f19e37e0555455ab4fa3e51ef3e9f2b</jid></bind></iq> > > > > DEBUG [2013 May 10 15:31:43.156] > > (HomeSecurityStanzaFilter.java:messageSent: > > 72) - > <iq xmlns="jabber:client" type="result" id="5aOWt-0"><bind xmlns > > ="urn:ietf:params:xml:ns:xmpp-bind"><jid>user1@hsvysper > > .org/7f19e37e0555455ab4fa3e51ef3e9f2b</jid></bind></iq> > > > > DEBUG [2013 May 10 15:31:43.157] (SslFilter.java:messageReceived:460) - > > Session Server[1](SSL): Message received : HeapBuffer[pos=0 lim=108 > > cap=256: 17 03 01 00 67 17 34 D0 2C CF 0D 3D F2 57 CB 46...] > > > > DEBUG [2013 May 10 15:31:43.158] (SslHandler.java:messageReceived:335) - > > Session Server[1](SSL) Processing the received message > > > > DEBUG [2013 May 10 15:31:43.158] (SslFilter.java:handleSslData:706) - > > Session Server[1](SSL): Processing the SSL Data > > > > DEBUG [2013 May 10 15:31:43.158] > (ProtocolCodecFilter.java:messageReceived > > :220) - Processing a MESSAGE_RECEIVED for session 1 > > > > DEBUG [2013 May 10 15:31:43.160] > (XMPPContentHandler.java:emitStanza:124) - > > Decoder writing stanza: <iq xmlns="jabber:client" id="5aOWt-1" > > type="set"><session > > xmlns="urn:ietf:params:xml:ns:xmpp-session"></session></ > > iq> > > > > DEBUG [2013 May 10 15:31:43.160] > (StanzaLoggingFilter.java:messageReceived > > :61) - < <iq xmlns="jabber:client" id="5aOWt-1" type="set"><session xmlns > > ="urn:ietf:params:xml:ns:xmpp-session"></session></iq> > > > > DEBUG [2013 May 10 15:31:43.161] (HomeSecurityStanzaFilter.java: > > messageReceived:56) - < <iq xmlns="jabber:client" id="5aOWt-1" > > type="set"><session > > xmlns="urn:ietf:params:xml:ns:xmpp-session"></session></ > > iq> > > > > DEBUG [2013 May 10 15:31:43.164] (SslFilter.java:filterWrite:581) - > Session > > Server[1](SSL): Writing Message : WriteRequest: HeapBuffer[pos=0 lim=78 > > cap=128: 3C 69 71 20 78 6D 6C 6E 73 3D 22 6A 61 62 62 65...] > > > > DEBUG [2013 May 10 15:31:43.164] (SslFilter.java:filterWrite:581) - > Session > > Server[1](SSL): Writing Message : MessageWriteRequest, parent : WR > > WrapperWriteRequest: [ prolog=false, open=true, close=true, content=true, > > stanza=[iq.id='5aOWt-1'.from='hsvysper.org'.type='result'] > > > > DEBUG [2013 May 10 15:31:43.165] > (StanzaLoggingFilter.java:messageSent:79) > > - > <iq xmlns="jabber:client" type="result" id="5aOWt-1" from="hsvysper > > .org"></iq> > > > > DEBUG [2013 May 10 15:31:43.166] > > (HomeSecurityStanzaFilter.java:messageSent: > > 72) - > <iq xmlns="jabber:client" type="result" id="5aOWt-1" > from="hsvysper > > .org"></iq> > > > > DEBUG [2013 May 10 15:31:43.171] (SslFilter.java:messageReceived:460) - > > Session Server[1](SSL): Message received : HeapBuffer[pos=0 lim=128 > > cap=128: 17 03 01 00 7B 65 5A AF 63 B8 88 40 0B C7 92 41...] > > > > DEBUG [2013 May 10 15:31:43.171] (SslHandler.java:messageReceived:335) - > > Session Server[1](SSL) Processing the received message > > > > DEBUG [2013 May 10 15:31:43.172] (SslFilter.java:handleSslData:706) - > > Session Server[1](SSL): Processing the SSL Data > > > > DEBUG [2013 May 10 15:31:43.172] > (ProtocolCodecFilter.java:messageReceived > > :220) - Processing a MESSAGE_RECEIVED for session 1 > > > > DEBUG [2013 May 10 15:31:43.174] > (XMPPContentHandler.java:emitStanza:124) - > > Decoder writing stanza: <iq xmlns="jabber:client" id="5aOWt-2" > > type="get"><query xmlns="jabber:iq:roster"></query></iq> > > > > DEBUG [2013 May 10 15:31:43.174] > (XMPPContentHandler.java:emitStanza:124) - > > Decoder writing stanza: <presence xmlns="jabber:client" > > id="5aOWt-3"></presence> > > > > DEBUG [2013 May 10 15:31:43.175] > (StanzaLoggingFilter.java:messageReceived > > :61) - < <iq xmlns="jabber:client" id="5aOWt-2" type="get"><query xmlns > > ="jabber:iq:roster"></query></iq> > > > > DEBUG [2013 May 10 15:31:43.175] (HomeSecurityStanzaFilter.java: > > messageReceived:56) - < <iq xmlns="jabber:client" id="5aOWt-2" > > type="get"><query xmlns="jabber:iq:roster"></query></iq> > > > > DEBUG [2013 May 10 15:31:43.230] > (StanzaLoggingFilter.java:messageReceived > > :61) - < <presence xmlns="jabber:client" id="5aOWt-3"></presence> > > > > DEBUG [2013 May 10 15:31:43.230] (HomeSecurityStanzaFilter.java: > > messageReceived:56) - < <presence xmlns="jabber:client" > > id="5aOWt-3"></presence> > > > > DEBUG [2013 May 10 15:31:43.231] (SslFilter.java:messageReceived:460) - > > Session Server[1](SSL): Message received : HeapBuffer[pos=0 lim=256 > > cap=256: 17 03 01 00 FF 70 08 22 A9 D2 E4 DC 97 7C 36 52...] > > > > DEBUG [2013 May 10 15:31:43.231] (SslHandler.java:messageReceived:335) - > > Session Server[1](SSL) Processing the received message > > > > DEBUG [2013 May 10 15:31:43.231] (SslFilter.java:handleSslData:706) - > > Session Server[1](SSL): Processing the SSL Data > > > > DEBUG [2013 May 10 15:31:43.232] (SslFilter.java:messageReceived:460) - > > Session Server[1](SSL): Message received : HeapBuffer[pos=0 lim=64 > cap=512: > > 26 59 DD 7F 17 03 01 00 20 E3 06 CF FD BC 61 B6...] > > > > DEBUG [2013 May 10 15:31:43.232] (SslHandler.java:messageReceived:335) - > > Session Server[1](SSL) Processing the received message > > > > DEBUG [2013 May 10 15:31:43.233] (SslFilter.java:handleSslData:706) - > > Session Server[1](SSL): Processing the SSL Data > > > > DEBUG [2013 May 10 15:31:43.233] (SslFilter.java:filterWrite:581) - > Session > > Server[1]: Writing Message : WriteRequest: HeapBuffer[pos=0 lim=23 > cap=32: > > 15 03 01 00 12 8D F0 20 B1 C7 09 50 C8 B8 51 EE...] > > > > DEBUG [2013 May 10 15:31:43.233] > (ProtocolCodecFilter.java:messageReceived > > :220) - Processing a MESSAGE_RECEIVED for session 1 > > > > DEBUG [2013 May 10 15:31:43.233] (SslFilter.java:filterWrite:581) - > Session > > Server[1]: Writing Message : WriteRequest: HeapBuffer[pos=0 lim=155 > > cap=256: 3C 69 71 20 78 6D 6C 6E 73 3D 22 6A 61 62 62 65...] > > > > WARN [2013 May 10 15:31:43.233] (PresenceAvailabilityHandler.java: > > handleOutboundAvailable:262) - No Offline Storage Provider configured > > > > DEBUG [2013 May 10 15:31:43.234] > (ProtocolCodecFilter.java:messageReceived > > :220) - Processing a MESSAGE_RECEIVED for session 1 > > > > DEBUG [2013 May 10 15:31:43.234] (SslFilter.java:filterWrite:581) - > Session > > Server[1]: Writing Message : MessageWriteRequest, parent : WR > > WrapperWriteRequest: [ prolog=false, open=true, close=true, content=true, > > stanza=[iq.id='5aOWt-2'.to='user1@hsvysper > > > .org/7f19e37e0555455ab4fa3e51ef3e9f2b'.type='result'.query.xmlns='jabber:iq > > :roster'] > > > > DEBUG [2013 May 10 15:31:43.235] > (XMPPContentHandler.java:emitStanza:124) - > > Decoder writing stanza: <message xmlns="jabber:client" to=" > > [email protected]" > > id="5aOWt-4" from="[email protected]/7f19e37e0555455ab4fa3e51ef3e9f2b" > > type="chat"><body>THIS IS MY TEST > > MESSAGE</body><thread>3XvCC0</thread></message> > > > > DEBUG [2013 May 10 15:31:43.236] > (XMPPContentHandler.java:emitStanza:124) - > > Decoder writing stanza: <presence xmlns="jabber:client" id="5aOWt-5" > > type="unavailable"></presence> > > > > DEBUG [2013 May 10 15:31:43.236] > (StanzaLoggingFilter.java:messageReceived > > :61) - < <message xmlns="jabber:client" to="[email protected]" > > id="5aOWt-4" from="[email protected]/7f19e37e0555455ab4fa3e51ef3e9f2b" > > type="chat"><body>THIS IS MY TEST > > MESSAGE</body><thread>3XvCC0</thread></message> > > > > DEBUG [2013 May 10 15:31:43.237] (HomeSecurityStanzaFilter.java: > > messageReceived:56) - < <message xmlns="jabber:client" to=" > > [email protected]" > > id="5aOWt-4" from="[email protected]/7f19e37e0555455ab4fa3e51ef3e9f2b" > > type="chat"><body>THIS IS MY TEST > > MESSAGE</body><thread>3XvCC0</thread></message> > > > > DEBUG [2013 May 10 15:31:43.237] > (StanzaLoggingFilter.java:messageReceived > > :61) - < <presence xmlns="jabber:client" id="5aOWt-5" > > type="unavailable"></presence> > > > > DEBUG [2013 May 10 15:31:43.238] (HomeSecurityStanzaFilter.java: > > messageReceived:56) - < <presence xmlns="jabber:client" id="5aOWt-5" > > type="unavailable"></presence> > > > > WARN [2013 May 10 15:31:43.257] > > (XmppIoHandlerAdapter.java:exceptionCaught: > > 140) - error caught on transportation layer: {} > > > > java.io.IOException: Broken pipe > > > > at sun.nio.ch.FileDispatcher.write0(Native Method) > > > > at sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:29) > > > > at sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:69) > > > > at sun.nio.ch.IOUtil.write(IOUtil.java:40) > > > > at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:336) > > > > at org.apache.mina.transport.socket.nio.NioProcessor.write(NioProcessor > > .java:221) > > > > at org.apache.mina.transport.socket.nio.NioProcessor.write(NioProcessor > > .java:42) > > > > at org.apache.mina.core.polling.AbstractPollingIoProcessor.writeBuffer( > > AbstractPollingIoProcessor.java:928) > > > > at org.apache.mina.core.polling.AbstractPollingIoProcessor.flushNow( > > AbstractPollingIoProcessor.java:852) > > > > at org.apache.mina.core.polling.AbstractPollingIoProcessor.flush( > > AbstractPollingIoProcessor.java:777) > > > > at org.apache.mina.core.polling.AbstractPollingIoProcessor.access$500( > > AbstractPollingIoProcessor.java:67) > > > > at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.run( > > AbstractPollingIoProcessor.java:1084) > > > > at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable > > .java:64) > > > > at > > java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor > > .java:895) > > > > at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor > > .java:918) > > > > at java.lang.Thread.run(Thread.java:680) > > > > DEBUG [2013 May 10 15:31:43.265] (SslFilter.java:filterWrite:581) - > Session > > Server[1]: Writing Message : WriteRequest: HeapBuffer[pos=0 lim=145 > > cap=256: 3C 65 72 72 6F 72 20 78 6D 6C 6E 73 3D 22 75 72...] > > > > DEBUG [2013 May 10 15:31:43.265] (SslFilter.java:filterWrite:581) - > Session > > Server[1]: Writing Message : MessageWriteRequest, parent : WR > > WrapperWriteRequest: [ prolog=false, open=true, close=true, content=true, > > stanza=[error.undefined-condition] > > > > INFO [2013 May 10 15:31:43.266] > (MinaBackedSessionContext.java:close:110) > > - session will be closed now > > > > INFO [2013 May 10 15:31:43.266] (MinaBackedSessionContext.java: > > operationComplete:126) - close future called > > > > INFO [2013 May 10 15:31:43.266] > (MinaBackedSessionContext.java:close:121) > > - session closed > > > > DEBUG [2013 May 10 15:31:43.267] (SslFilter.java:filterWrite:581) - > Session > > Server[1]: Writing Message : WriteRequest: HeapBuffer[pos=0 lim=208 > > cap=256: 3C 6D 65 73 73 61 67 65 20 78 6D 6C 6E 73 3D 22...] > > > > DEBUG [2013 May 10 15:31:43.266] (SslFilter.java:filterWrite:581) - > Session > > Server[1]: Writing Message : WriteRequest: HeapBuffer[pos=0 lim=172 > > cap=256: 3C 70 72 65 73 65 6E 63 65 20 78 6D 6C 6E 73 3D...] > > > > DEBUG [2013 May 10 15:31:43.267] (SslFilter.java:filterWrite:581) - > Session > > Server[1]: Writing Message : MessageWriteRequest, parent : WR > > WrapperWriteRequest: [ prolog=false, open=true, close=true, content=true, > > stanza=[message.body.THIS IS MY TEST MESSAGE] > > > > DEBUG [2013 May 10 15:31:43.267] (SessionStateHolder.java:setState:43) - > > session state changed to = CLOSED > > > > DEBUG [2013 May 10 15:31:43.267] (SslFilter.java:filterWrite:581) - > Session > > Server[1]: Writing Message : MessageWriteRequest, parent : WR > > WrapperWriteRequest: [ prolog=false, open=true, close=true, content=true, > > stanza=[presence.from='user1@hsvysper > > .org/7f19e37e0555455ab4fa3e51ef3e9f2b'.to='user1@hsvysper > > .org/7f19e37e0555455ab4fa3e51ef3e9f2b'] > > > > INFO [2013 May 10 15:31:43.268] (PresenceAvailabilityHandler.java: > > handleInboundAvailable:447) - > > [email protected]/7f19e37e0555455ab4fa3e51ef3e9f2b > > has become available > > > > INFO [2013 May 10 15:31:43.269] > (MinaBackedSessionContext.java:close:110) > > - session will be closed now > > > > INFO [2013 May 10 15:31:43.270] > (MinaBackedSessionContext.java:close:121) > > - session closed > > > > DEBUG [2013 May 10 15:31:43.270] (SessionStateHolder.java:setState:43) - > > session state changed to = CLOSED > > > > INFO [2013 May 10 15:31:43.270] > (XmppIoHandlerAdapter.java:sessionClosed: > > 120) - session d81fde63f689463a8e138031d0713139 has been closed > > > > > > > > > > > > -- > > Frank Arico > > [email protected]< > > https://mail.google.com/mail/?view=cm&fs=1&tf=1&[email protected] > > > > Home: 610-902-0950 > > Cell: 610-212-5476 > > > Question; Can I intercept and process messages sent to my vysper server to an arbitrary user without the user being logging into my server ? We have a vendor whose product uses XMPP to communicate from athe user's home all security events and alarms to their XMPP server. The problem domain is home security and automation. We want the vendor to also send the XMPP stream to our vysper server so that we can process them and send the alarms to the user's mobile. The vendor's product does not currently do this. This has to scale to 100K + users. It works fine when I havea test user logger into the system but blows up when the user is not logged in. I saw your other email . Should I try that? -- Frank Arico [email protected] Home: 610-902-0950 Cell: 610-212-5476
