Rabbitmq - php amqp broken broken pipe error -


i processing huge xml document (which contains around million entries) , subsequently importing formatted version db using rabbitmq. each time after publishing around 200,000 entries receive broken pipe error , , rabbitmq unable recover it.

notice error: fwrite(): send of 2651 bytes failed errno=11 resource temporarily unavailable in [/var/www/ribbon/app/console/command/lib/php_amqplib/amqp.inc, line 439]

notice error: fwrite(): send of 33 bytes failed errno=104 connection reset peer in [/var/www/ribbon/app/console/command/lib/php_amqplib/amqp.inc, line 439]

notice error: fwrite(): send of 19 bytes failed errno=32 broken pipe in [/var/www/ribbon/app/console/command/lib/php_amqplib/amqp.inc, line 439]

this subsequently causes node down error , process needs manually killed recover it.

these class methods:-

public function publishmessage($message) {     if (!isset($this->conn)) {         $this->_createnewconnectionandchannel();     }     try {         $this->ch->basic_publish(             new amqpmessage($message, array('content_type' => 'text/plain')),              $this->defaults['exchange']['name'],              $this->defaults['binding']['routing_key']         );     } catch (exception $e) {         echo "caught exception : " . $e->getmessage();         echo "creating new connection.";         $this->_createnewconnectionandchannel();         $this->publishmessage($message); // try again     } }  protected function _createnewconnectionandchannel() {     if (isset($this->conn)) {         $this->conn->close();     }      if(isset($this->ch)) {         $this->ch->close();     }      $this->conn = new amqpconnection(         $this->defaults['connection']['host'],          $this->defaults['connection']['port'],          $this->defaults['connection']['user'],          $this->defaults['connection']['pass']     );     $this->ch = $this->conn->channel();     $this->ch->access_request($this->defaults['channel']['vhost'], false, false, true, true);     $this->ch->basic_qos(0 , 20 , 0); // fair dispatching      $this->ch->queue_declare(         $this->defaults['queue']['name'],         $this->defaults['queue']['passive'],         $this->defaults['queue']['durable'],         $this->defaults['queue']['exclusive'],         $this->defaults['queue']['auto_delete']     );      $this->ch->exchange_declare(         $this->defaults['exchange']['name'],         $this->defaults['exchange']['type'],         $this->defaults['exchange']['passive'],         $this->defaults['exchange']['durable'],         $this->defaults['exchange']['auto_delete']     );      $this->ch->queue_bind(         $this->defaults['queue']['name'],         $this->defaults['exchange']['name'],         $this->defaults['binding']['routing_key']     ); }

any appreciated.

make sure have added virtualhost access user on rabbit mq. i've created new user , forgot set access rights "/" host used default.

you can via management panel yourhost:15672 > admin > click on user > "set permission".

p.s. assume rabbitmq service running, user exists , password correct.


Comments

Post a Comment

Popular posts from this blog

monitor web browser programmatically in Android? -

i've got tricky question here. need users make payment bank (namely barclaycard) in uk. so, have https url , add parameters (such amount pay, order reference, etc) url, start http connection intent.actionview, redirect user browser can enter credit card details on bank's webpage , make payment our account successfully. far ? the code use below (i changed values privacy reasons) problem is, need app when user has completed/failed/cancelled payment. barclaycardautomatically redirects particular url when payment has succeeded, 1 if failed. there no way of knowing when barclaycard payment has succeeded go android app somehow ? button cardbutton = (button) findviewbyid(r.id.card_button); cardbutton.setonclicklistener(new view.onclicklistener() { @override public void onclick(view arg0) { string prehashstring = new string(); string prohashstring = new string(); string shapassphrase = new string(); shapassphrase = "gsvth£h70zkh...
Read more

Shrink a YouTube video to responsive width -

i have youtube video embedded on our website , when shrink screen tablet or phone sizes stops shrinking @ around 560px in width. standard youtube videos or there can add code make go smaller? you can make youtube videos responsive css. wrap iframe in div class of "videowrapper" , apply following styles: .videowrapper { float: none; clear: both; width: 100%; position: relative; padding-bottom: 56.25%; padding-top: 25px; height: 0; } .videowrapper iframe { position: absolute; top: 0; left: 0; width: 100%; height: 100%; } the .videowrapper div should inside responsive element. padding on .videowrapper necessary keep video collapsing. may have tweak numbers depending upon layout.
Read more

wpf - PdfWriter.GetInstance throws System.NullReferenceException -

i'm trying create pdf document using itextsharp 5.3.4 using following document document = new document(); filestream stm = new filestream(filename, filemode.create); pdfwriter writer = pdfwriter.getinstance(document, stm); i'm getting system.nullreferenceexception following stack trace: system.nullreferenceexception occurred hresult=-2147467261 message=la référence d'objet n'est pas définie à une instance d'un objet. source=itextsharp stacktrace: à itextsharp.text.version.getinstance() innerexception: i've verified neither document nor stm null, , if select "continue" in vs12 document created - exception thrown. updated itextsharp 5.4.0 , it's still occurring. can't find information on anywhere - got ideas? make sure not catching exceptions. nullreferenceexception can 1 caught , handled inside itextsharp, don't care it. fact can continue supports theory. change following setting verify: debug -> exceptions ...
Read more