Skip to content

Instantly share code, notes, and snippets.

<?php
require('vendor/autoload.php');
use PhpAmqpLib\Connection\AMQPConnection;
use PhpAmqpLib\Connection\AMQPLazyConnection;
use PhpAmqpLib\Connection\AMQPSocketConnection;
use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Channel\AMQPChannel;
use PhpAmqpLib\Message\AMQPMessage;
-- CONSUMER LOG
Tue, 16 Feb 2016 15:51:49 +0000: wait exception : Error sending data. Socket connection timed out
Tue, 16 Feb 2016 15:51:52 +0000:reconnect exception : stream_socket_client(): unable to connect to tcp://172.24.55.150:5672 (Operation timed out)
Tue, 16 Feb 2016 15:51:52 +0000:received :
Tue, 16 Feb 2016 15:51:55 +0000: wait exception : stream_socket_client(): unable to connect to tcp://172.24.55.150:5672 (Operation timed out)
[16-Feb-2016 15:51:58 Etc/UTC] PHP Fatal error: Allowed memory size of 134217728 bytes exhausted (tried to allocate 1342177291 bytes) in /Users/bmcgavin/rmq-tests/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Wire/IO/StreamIO.php on line 202
[16-Feb-2016 15:51:58 Etc/UTC] PHP Stack trace:
[16-Feb-2016 15:51:58 Etc/UTC] PHP 1. {main}() /Users/bmcgavin/rmq-tests/rabbitmq_consumer.php:0
172.24.55.171 is the consumer machine, 172.24.55.150 is the broker.
See line 631 for the start of the packet from the broker containing the 'AMQP' header, causing the consumer's OOM error.
15:51:40.304820 IP (tos 0x0, ttl 64, id 31560, offset 0, flags [DF], proto TCP (6), length 64, bad cksum 0 (->f7fd)!)
172.24.55.171.51819 > 172.24.55.150.5672: Flags [S], cksum 0xc7a4 (incorrect -> 0xdeb5), seq 822858432, win 65535, options [mss 1460,nop,wscale 5,nop,nop,TS val 1522356664 ecr 0,sackOK,eol], length 0
0x0000: 4500 0040 7b48 4000 4006 0000 ac18 37ab E..@{H@.@.....7.
0x0010: ac18 3796 ca6b 1628 310b d2c0 0000 0000 ..7..k.(1.......
0x0020: b002 ffff c7a4 0000 0204 05b4 0103 0305 ................
0x0030: 0101 080a 5abd 51b8 0000 0000 0402 0000 ....Z.Q.........

Keybase proof

I hereby claim:

  • I am bmcgavin on github.
  • I am bmcgavin (https://keybase.io/bmcgavin) on keybase.
  • I have a public key whose fingerprint is D6AC 7FFF A80B F347 12DF 3D95 CD82 B0C7 86BE 6C9A

To claim this, I am signing this object:

{
"config": {
"log": "info"
},
"source" :{
"file": {"path":"/home/vagrant/duplicate_indexed_edge.json"}
},
"extractor" : {
"json": {}
},
[
{"articleId":"12345","linkedArticles":["54321"]}
]
[
{"articleId":"1","linkedArticles":["2"]},
{"articleId":"2","linkedArticles":["1"]}
]
{
"config": {
"log": "debug"
},
"source" :{
"file": {"path":"/home/vagrant/bugreport_testcase_minimal.json"}
},
"extractor" : {
"json": {}
},
@bmcgavin
bmcgavin / init.sh
Created May 20, 2012 21:24 — forked from lrvick/init.sh
Chrooted Arch Linux environment setup script for Android
USER='lrvick'
cd /data/local/arch
if ! mountpoint -q dev; then
mount -t proc /proc proc
mount -o bind /dev dev
mount -o bind /dev/pts /data/local/arch/dev/pts
fi