Return-Path: X-Original-To: apmail-apex-dev-archive@minotaur.apache.org Delivered-To: apmail-apex-dev-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id C31C91825A for ; Mon, 12 Oct 2015 16:12:27 +0000 (UTC) Received: (qmail 70210 invoked by uid 500); 12 Oct 2015 16:12:22 -0000 Delivered-To: apmail-apex-dev-archive@apex.apache.org Received: (qmail 70150 invoked by uid 500); 12 Oct 2015 16:12:22 -0000 Mailing-List: contact dev-help@apex.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@apex.incubator.apache.org Delivered-To: mailing list dev@apex.incubator.apache.org Received: (qmail 70138 invoked by uid 99); 12 Oct 2015 16:12:22 -0000 Received: from Unknown (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 12 Oct 2015 16:12:22 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id ED711180A66 for ; Mon, 12 Oct 2015 16:12:21 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.899 X-Spam-Level: ** X-Spam-Status: No, score=2.899 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, HTML_MESSAGE=3, RCVD_IN_MSPIKE_H2=-0.001, SPF_PASS=-0.001, URIBL_BLOCKED=0.001] autolearn=disabled Authentication-Results: spamd3-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-us-east.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id VrKpnydM3AZe for ; Mon, 12 Oct 2015 16:12:16 +0000 (UTC) Received: from mail-pd0-f189.google.com (mail-pd0-f189.google.com [209.85.192.189]) by mx1-us-east.apache.org (ASF Mail Server at mx1-us-east.apache.org) with ESMTPS id D190142F38 for ; Mon, 12 Oct 2015 16:12:15 +0000 (UTC) Received: by pdbdq3 with SMTP id dq3so23627130pdb.1 for ; Mon, 12 Oct 2015 09:12:09 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=date:from:to:cc:message-id:in-reply-to:references:subject :mime-version:content-type; bh=7C8egpoTWFE3PdIKVFY6lucY6DUSmztJuu7fkGFB1Ag=; b=sTsnZX7BH43ntqTyZpIp86ZMOHl0rRiZY22hxqTqE3aC0aEss/7Xkw6X3DE32wPenl 6ajlk7ptPSsgcGpnszgC4iGelfG/MCdbGX4WrFZC3eemQcPQTtLXC3ZkVyptb2Tj7V4M mLCxrCMt4yQsDqkJP+OdwK7vzIf8Qb16W42EyYvvPIRDcmyRiKTy7kPNi0T5ZiH06AkR g7yw1KXV+pxPRSjfpa9lgWqbecyay8ixsHx2Skb2+gFXyhjApIKq4qnwLWq8QqUZNS/M 0zFprwzOeLqD8qFUrBgv7d1voFXU6kwTmnXNG6C3uT8SZH92r/mpx61eSg4xLyGP5A9l YSPA== X-Received: by 10.182.120.168 with SMTP id ld8mr147479obb.33.1444666329739; Mon, 12 Oct 2015 09:12:09 -0700 (PDT) X-Google-Doc-Id: 6e004f87efa37 X-Google-Web-Client: true Date: Mon, 12 Oct 2015 09:12:09 -0700 (PDT) From: Eric Asuncion To: Malhar Cc: dev@apex.incubator.apache.org Message-Id: <3d836275-df0d-4437-ac32-49bfabaea359@googlegroups.com> In-Reply-To: References: <2fa5443a-5942-4485-90de-fac6a72f9c6f@googlegroups.com> <83694B13-C469-44AA-9061-BA742293BEDE@gmail.com> Subject: Re: [malhar-users] JMS sample application MIME-Version: 1.0 Content-Type: multipart/mixed; boundary="----=_Part_1818_858925653.1444666329112" X-Google-Token: ENm377AFJqrA66uhsGQ0 X-Google-IP: 202.156.49.130 ------=_Part_1818_858925653.1444666329112 Content-Type: multipart/alternative; boundary="----=_Part_1819_11608124.1444666329113" ------=_Part_1819_11608124.1444666329113 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 7bit Hi, Replaced ActiveMQ JMS implementation jar with Solace JMS jar files in the package archive and I encountered the following error: Abandoning deployment due to setup failure. java.lang.RuntimeException: Failed to create connection factory. at com.datatorrent.lib.io.jms.JMSBase.getConnectionFactory(JMSBase.java:372) at com.datatorrent.lib.io.jms.JMSBase.createConnection(JMSBase.java:336) at com.datatorrent.lib.io.jms.AbstractJMSInputOperator.activate(AbstractJMSInputOperator.java:235) at com.datatorrent.lib.io.jms.AbstractJMSInputOperator.activate(AbstractJMSInputOperator.java:70) at com.datatorrent.stram.engine.Node.activate(Node.java:579) at com.datatorrent.stram.engine.StreamingContainer.setupNode(StreamingContainer.java:1299) at com.datatorrent.stram.engine.StreamingContainer.access$100(StreamingContainer.java:87) at com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1346) Caused by: java.lang.ClassCastException: com.solacesystems.jndi.SolJNDIInitialContextFactory cannot be cast to javax.jms.ConnectionFactory at com.datatorrent.lib.io.jms.JMSBase.getConnectionFactory(JMSBase.java:363) ... 7 more Note, I build my test application using DT 3.0 version and running it on DT Sandbox release. Any idea? Should I use 3.1.1-RC2 release to build my test app? I tried to build it using 3.1 but encountered "netlet-1.2.0-SNAPSHOT.jar is missing" error. Thanks, Eric On Friday, 9 October 2015 20:54:58 UTC+8, Priyanka Gugale wrote: > > We are shipping activeMQ client jar with dtIngest. You should be able to > have any JMS server and dtIngest should read messages from that. If you > face any issues please let us know. > > -Priyanka > > On Fri, Oct 9, 2015 at 5:27 PM, Eric Asuncion > wrote: > >> Quite simple use case; subscribe to JMS topic and archive message in >> Hadoop for later analysis. >> >> How do you add the JMS implementation provider Jar files? Do I need to >> add them to DT classpath configuration? >> >> Apology for simple query since I am new to DT/Apex. >> >> >> >> On 9 Oct 2015, at 6:39 pm, Priyanka Gugale > > wrote: >> >> Hi Eric, >> >> Can you elaborate on your use case? >> >> We have JMS input operator. And we also have dtIngest application which >> is free to use (not open sourced though). Once configured for JMS input, >> dtIngest will read JMS message and sent it to some file based destination >> or other messaging systems like kafka etc. You can read about dtIngest >> here >> . >> It's also available for download on Datatorrent site. >> >> >> -Priyanka >> >> >> >> On Fri, Oct 9, 2015 at 3:51 PM, Eric Asuncion > > wrote: >> >>> Hi, >>> >>> Any sample demos/applications that ingests JMS messages? >>> >>> Thanks, >>> Eric >>> >>> -- >>> You received this message because you are subscribed to the Google >>> Groups "Malhar" group. >>> To unsubscribe from this group and stop receiving emails from it, send >>> an email to malhar-users...@googlegroups.com . >>> To post to this group, send email to malhar...@googlegroups.com >>> . >>> Visit this group at http://groups.google.com/group/malhar-users. >>> For more options, visit https://groups.google.com/d/optout. >>> >> >> -- >> You received this message because you are subscribed to a topic in the >> Google Groups "Malhar" group. >> To unsubscribe from this topic, visit >> https://groups.google.com/d/topic/malhar-users/SDVmCEyuH0Y/unsubscribe. >> To unsubscribe from this group and all its topics, send an email to >> malhar-users...@googlegroups.com . >> To post to this group, send email to malhar...@googlegroups.com >> . >> Visit this group at http://groups.google.com/group/malhar-users. >> For more options, visit https://groups.google.com/d/optout. >> >> -- >> You received this message because you are subscribed to the Google Groups >> "Malhar" group. >> To unsubscribe from this group and stop receiving emails from it, send an >> email to malhar-users...@googlegroups.com . >> To post to this group, send email to malhar...@googlegroups.com >> . >> Visit this group at http://groups.google.com/group/malhar-users. >> For more options, visit https://groups.google.com/d/optout. >> > > ------=_Part_1819_11608124.1444666329113 Content-Type: text/html; charset=utf-8 Content-Transfer-Encoding: quoted-printable
Hi,

Replaced ActiveMQ JMS implementatio= n jar with Solace JMS jar files in the package archive and I encountered th= e following error:

Abandoning deployment due = to setup failure. java.lang.RuntimeException: Failed to create connection f= actory.
= =09at com.datatorrent.lib.io.jms.JMSBase.getConnectionFactory(JMSBas= e.java:372)
=09at com.datatorrent.lib.io.jms.JMSBase.createConnection(JMSBas= e.java:336)
=09at com.datatorrent.lib.io.jms.AbstractJMSInputOperator.activa= te(AbstractJMSInputOperator.java:235)
=09at com.datatorrent.lib.io.jms.Abstr= actJMSInputOperator.activate(AbstractJMSInputOperator.java:70)
=09at com.dat= atorrent.stram.engine.Node.activate(Node.java:579)
=09at com.datatorrent.str= am.engine.StreamingContainer.setupNode(StreamingContainer.java:1299)
<= div>=09at c= om.datatorrent.stram.engine.StreamingContainer.access$100(StreamingContaine= r.java:87)
=09at com.datatorrent.stram.engine.StreamingContainer$2.run(Strea= mingContainer.java:1346)
Caused by: java.lang.ClassCastException:= com.solacesystems.jndi.SolJNDIInitialContextFactory cannot be cast to java= x.jms.ConnectionFactory
=09at com.datatorrent.lib.io.jms.JMSBase.getConnecti= onFactory(JMSBase.java:363)
=09... 7 more

Note, I = build my test application using DT =C2=A03.0 version and running it on DT S= andbox release. Any idea? Should I use=C2=A03.1.1-RC2=C2=A0release to build= my test app? I tried to build it using 3.1 but encountered "netlet-1.= 2.0-SNAPSHOT.jar is missing" error.

Thanks,
Eric

On Friday, 9 October 2015 20:54:58 UTC+8, Priyanka G= ugale wrote:
= We are shipping activeMQ client jar with dtIngest. You should be able to ha= ve any JMS server and dtIngest should read messages from that. If you face = any issues please let us know.

-Priyanka=C2=A0

On Fri, Oct 9, 2015 at 5:27 PM, Eric = Asuncion <easu...@gmail.com> wrote:
Quite simple use case; subs= cribe to JMS topic and archive message in Hadoop for later analysis.
<= div>
How do you add the JMS implementation provider Jar files= ? Do I need to add them to DT classpath configuration?=C2=A0

=
Apology for simple query since I am new to DT/Apex.


<= /div>

On 9 Oct 2015, at 6:39 pm, Priyanka Gugale <priy...@d= atatorrent.com> wrote:

Hi Eric,

Can you e= laborate on your use case?

We have JMS input opera= tor. And we also have dtIngest application which is free to use (not open s= ourced though). Once configured for JMS input, dtIngest will read JMS messa= ge and sent it to some file based destination or other messaging systems li= ke kafka etc. You can read about dtIngest here. It= 's also available for download on Datatorrent site.<= /a>



<= /div>

On Fri, Oct 9, 2015 at 3:51 PM, Er= ic Asuncion <easu...@gmail.com> wrote:
Hi,=C2=A0

A= ny sample demos/applications that ingests JMS messages?

Thanks,
Eric

--
You received this message because you are subscribed to the Google Groups &= quot;Malhar" group.
To unsubscribe from this group and stop receiving emails from it, send an e= mail to malhar-users...@googlegroups.com.
To post to this group, send email to malhar...@googlegroups.com.
Visit this group at htt= p://groups.google.com/group/malhar-users.
For more options, visit https://groups.google.com/= d/optout.

--
You received this message because you are subscribed to a topic in the Goog= le Groups "Malhar" group.
To unsubscribe from this topic, visit https://groups.google.com/d/topic/malhar-users/= SDVmCEyuH0Y/unsubscribe.
To unsubscribe from this group and all its topics, send an email to malhar-users= ...@googlegroups.com.
To post to this group, send email to malhar...@googlegroups.com.
Visit this group at htt= p://groups.google.com/group/malhar-users.
For more options, visit https://groups.google.com/= d/optout.

--
You received this message because you are subscribed to the Google Groups &= quot;Malhar" group.
To unsubscribe from this group and stop receiving emails from it, send an e= mail to malhar-users...@googlegroups.com.
To post to this group, send email to malhar...@googlegroups.com.
Visit this group at htt= p://groups.google.com/group/malhar-users.
For more options, visit https://groups.google.com/= d/optout.

------=_Part_1819_11608124.1444666329113-- ------=_Part_1818_858925653.1444666329112--