skybet / amqpea Goto Github PK
View Code? Open in Web Editor NEWNode.js AMQP client
amqpea's People
Contributors
Stargazers
Watchers
Forkers
danrspencer glenjamin northcoders-chris johnsonp82 iainb grynienp thomaslomas alexmtv tf-redfreeamqpea's Issues
Support for AMQPS (SSL/TLS connections)
Do you have an example of connecting over amqps:// scheme URI instead of plain amqp://?
Possible race condition when doing multiple queue.bind calls
Travis is broken
Not sure why, don't have time to find out right now: https://travis-ci.org/skybet/amqpea
The code hasn't changed, so must be environmental.
Buffer error connecting to ActiveMQ docker container
Docker command for my container:
- Assume docker running on 192.168.123.123 in OracleBox.
docker run --name data-activemq -p 1883:1883 -p 5672:5672 -p 8161:8161 -p 61613:61613 -p 61614:61614 -p 61616:61616 -e 'ACTIVEMQ_MIN_MEMORY=512' -e 'ACTIVEMQ_MAX_MEMORY=2048' -v $DATA_PATH/activemq:/data/activemq -h data-activemq -d webcenter/activemq:5.12.0
Connection url used:
- See the all-in-one example from your page https://www.npmjs.com/package/amqpea
var targetUri = 'amqp://guest:[email protected]:61616/%2F';
Errors received:
$ node ActiveMQ-AmqPea-Pub-Sub.js
--connect--
... targetUri = amqp://guest:[email protected]:61616/%2F
--die--
C:\git\queue-demo\ActiveMQ-AmqPea-Pub-Sub.js:58
throw err;
^
RangeError: Attempt to allocate Buffer larger than maximum size: 0x3fffffff bytes
at new Buffer (buffer.js:71:11)
at FrameParser.parseFrameStart (C:\git\queue-demo\node_modules\amqpea\node_modules\bramqp\lib\frameParser.js:367:29)
at FrameParser.parse (C:\git\queue-demo\node_modules\amqpea\node_modules\bramqp\lib\frameParser.js:433:57)
at Socket.<anonymous> (C:\git\queue-demo\node_modules\amqpea\node_modules\bramqp\lib\connectionHandle.js:54:22)
at Socket.g (events.js:199:16)
at Socket.emit (events.js:107:17)
at readableAddChunk (_stream_readable.js:163:16)
at Socket.Readable.push (_stream_readable.js:126:10)
at TCP.onread (net.js:538:20)Hard to look through logs of multiple connections
e.g.
AMQP listener attached for "connection.start"
AMQP listener attached for "connection.start"
AMQP 0 in connection.start {"version-major":0,"version-minor":9,"server-properties":{"capabilities":{"publisher_confirms":true,"exchange_exchange_bindings":true,"basic.nack":true,"consumer_cancel_notify":true,"connection.blocked":true,"consumer_priorities":true,"authentication_failure_close":true},"copyright":"Copyright (C) 2007-2013 GoPivotal, Inc.","information":"Licensed under the MPL. See http://www.rabbitmq.com/","platform":"Erlang/OTP","product":"RabbitMQ","version":"3.2.3"},"mechanisms":"PLAIN AMQPLAIN","locales":"en_US"}
AMQP to 0 connection.start-ok {"client-properties":{"product":{"type":"Long string","data":"obdata-feed"},"version":{"type":"Long string","data":"gueatrdapp01 pid 25658"},"platform":{"type":"Long string","data":"Linux/Node.js/AMQPea/0.3.0"}},"mechanism":"AMQPLAIN","response":{"LOGIN":{"type":"Long string","data":"orwell"},"PASSWORD":{"type":"Long string","data":"******"}},"locale":"en_US"}
AMQP listener attached for "connection.tune"
AMQP listener attached for "connection.start"
AMQP 0 in connection.start {"version-major":0,"version-minor":9,"server-properties":{"capabilities":{"publisher_confirms":true,"exchange_exchange_bindings":true,"basic.nack":true,"consumer_cancel_notify":true,"connection.blocked":true,"consumer_priorities":true,"authentication_failure_close":true},"copyright":"Copyright (C) 2007-2013 GoPivotal, Inc.","information":"Licensed under the MPL. See http://www.rabbitmq.com/","platform":"Erlang/OTP","product":"RabbitMQ","version":"3.2.3"},"mechanisms":"PLAIN AMQPLAIN","locales":"en_US"}
AMQP 0 in connection.tune {"channel-max":0,"frame-max":131072,"heartbeat":580}
No indication of which log message belongs to which connection
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.