From users-return-49366-archive-asf-public=cust-asf.ponee.io@activemq.apache.org Wed Feb 14 00:22:49 2018 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx-eu-01.ponee.io (Postfix) with SMTP id C84E7180656 for ; Wed, 14 Feb 2018 00:22:48 +0100 (CET) Received: (qmail 20952 invoked by uid 500); 13 Feb 2018 23:22:47 -0000 Mailing-List: contact users-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@activemq.apache.org Delivered-To: mailing list users@activemq.apache.org Received: (qmail 20926 invoked by uid 99); 13 Feb 2018 23:22:46 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 13 Feb 2018 23:22:46 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id 6A45CC0118 for ; Tue, 13 Feb 2018 23:22:46 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.879 X-Spam-Level: * X-Spam-Status: No, score=1.879 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd4-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id 88oCSSO4ux1k for ; Tue, 13 Feb 2018 23:22:45 +0000 (UTC) Received: from mail-wm0-f45.google.com (mail-wm0-f45.google.com [74.125.82.45]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id 29DA05F1ED for ; Tue, 13 Feb 2018 23:22:44 +0000 (UTC) Received: by mail-wm0-f45.google.com with SMTP id v71so18880529wmv.2 for ; Tue, 13 Feb 2018 15:22:44 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=from:subject:to:references:message-id:date:user-agent:mime-version :in-reply-to:content-language; bh=U2h8mZ6H90RceByhCF5pzh3Y5vAMj+6/8taqFkXL5kE=; b=C5NHo7/1UnsKz6FJV7nmcqWdpjSqSHbLTdm8NTJpJzrXgYbEzVUCsogEt8FL4pD0i1 +zRTAv/7yYDs9AlprEOPjf4KmbB3YVaIBDeGuf0gs9d08xgzAKLa+tSGPaXV1nUU0zpz idymhWyDeH/afRBqPQ/XcZeVsf854hwqcpGrT0fG3j6IEXlxpOnTezNz0VCVVQ/W16T/ hlQOSn9Qq4T8LKfV/C0IuKmcQ0aOt/WXQCjPy2eKegUaJw0Nsc6QHdHJGNnCxNMf1mTF 3GMa9dKdPz9d7iCde2V8SsNYmRIUFBVSWPU6cnXFFS92YcfIT3zRM7P7AAdFUibT+bvt EZCg== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:from:subject:to:references:message-id:date :user-agent:mime-version:in-reply-to:content-language; bh=U2h8mZ6H90RceByhCF5pzh3Y5vAMj+6/8taqFkXL5kE=; b=MUpiJTj0+lU2Hv4u/gLgNUp5OjCbkWqlEOdAs0c9VCkoUYR0lxhokFFQhEkTSof/Dk V2S0ullLpjl6Gv/Qe924Ku3Xg5RUoiU3zsoTU2KZ6kU/92+4noWaoTxJLqhOI7tXQOtN CahHsCO4DC+AKpSj0lh4LXY9ule9xyxWzOxYuvn33XQPKZ2rAUZPk1QudsmebJSgoK/z A6qtBM47HbKWeu3YxFme4FuvWl5AwjFbXXLlTUsL5KM0I/47/7QAiFsOKfT7t5k/k3G1 34DoBFiYPlU+l70unLw5ILRYn89GQN9G1gP4TFe/2lgCnF9DxCQkOJyZvXBsTW/kXNHs lfFQ== X-Gm-Message-State: APf1xPDo/NeCMzFTC5/9IT6IAmelo11knTfu/ZS6SCJbFk6t9FalsSBL wXw59KRWG7ooZ8DJU5NJFg4= X-Google-Smtp-Source: AH8x22769+gaFNwsTUUn4E4v91pqPOfIcV5Fv8bajq9+evkVKktApc7CcvxafExqOQtuaggZeL9iGQ== X-Received: by 10.80.141.197 with SMTP id s5mr4215592edh.0.1518564158378; Tue, 13 Feb 2018 15:22:38 -0800 (PST) Received: from Jeroens-MacBook-Pro.local (h140235.upc-h.chello.nl. [62.194.140.235]) by smtp.gmail.com with ESMTPSA id p14sm8008631edj.46.2018.02.13.15.22.37 (version=TLS1_2 cipher=ECDHE-RSA-AES128-GCM-SHA256 bits=128/128); Tue, 13 Feb 2018 15:22:37 -0800 (PST) From: Jeroen van Ooststroom X-Google-Original-From: Jeroen van Ooststroom Subject: Re: Trying to send and receive text messages using ActiveMQ with JavaScript (AMQP) and Java (OpenWire/JMS) clients To: users@activemq.apache.org, Timothy Bish References: <5de54202-06c3-df0d-2415-5a016c919177@Gmail.com> <028b00fe-bd63-98f5-c5af-6cf76af36cce@gmail.com> Message-ID: Date: Wed, 14 Feb 2018 00:22:36 +0100 User-Agent: Mozilla/5.0 (Macintosh; Intel Mac OS X 10.12; rv:52.0) Gecko/20100101 Thunderbird/52.6.0 MIME-Version: 1.0 In-Reply-To: <028b00fe-bd63-98f5-c5af-6cf76af36cce@gmail.com> Content-Type: multipart/alternative; boundary="------------2BE8071504B69479DA376D91" Content-Language: en-US --------------2BE8071504B69479DA376D91 Content-Type: text/plain; charset=utf-8; format=flowed Content-Transfer-Encoding: 8bit Thank you for your response. When I upgrade to ActiveMQ 5.15.3 my simple JavaScript client isn't able to connect to the AMQP connector anymore: error on read: ProtocolError: SASL layer not enabled (buffer:0x41,0x4d,0x51,0x50,0x03,0x01,0x00,0x00) I'm not familiar with this. Does this mean I require a SASL client now with a username/password to authenticate? (https://github.com/grs/rhea/blob/master/examples/sasl/simple_sasl_client.js) If so, I assume this affects the way the Java client connects as well? Thanks, Jeroen... On 13/02/2018 23:45, Timothy Bish wrote: > On 02/13/2018 05:29 PM, Jeroen van Ooststroom wrote: >> I have a simple test JavaScript (Node.js) client that connects to >> ActiveMQ using AMQP and our Java client that connects to the same >> ActiveMQ using OpenWire (JMS). When I send a message from the >> JavaScript client (just a simple “Hello World!”) it is received by >> the Java client as a javax.jms.BytesMessage. However the contents of >> this BytesMessage contains a bunch of bytes in front of the actual >> “Hello World!” message: >> >>    “SpESsESw� >>    Hello World!” >> >> I'm using the ActiveMQ's (5.13.4) and Qpid's suggested Rhea >> JavaScript (Node.js) library for the simple JavaScript client for >> testing. On the Java-side of things I'm using plain JMS 1.0. >> >> The Rhea example I'm using is basically according to this sample: >> https://github.com/grs/rhea/blob/master/examples/helloworld.js >> >> I'm using the default AMQP configuration in order to enable the >> protocol in activemq.xml: >> >>    > uri="amqp://0.0.0.0:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> >> >> >> When I try to add "&transport.transformer=jms" or >> "&transport.transformer=raw" the JavaScript client is unable to >> connect anymore. >> >> How do I get it so that it only contains the “Hello World!” message? >> Do I need to parse out the bytes contained in the BytesMessage? >> >> Thanks, >> Jeroen... >> >> > Try upgrading to ActiveMQ 5.15.3 which will have improved AMQP support > over that older version. > --------------2BE8071504B69479DA376D91--