Skip to content

Replaced fsockoen with stream_socket_client, added timeout as constructor parameter #25

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
rethab wants to merge 9 commits into
base: master
Choose a base branch
from
Open

Replaced fsockoen with stream_socket_client, added timeout as constructor parameter #25

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
9 commits
Select commit Hold shift + click to select a range
c38e9d2
Changed to new stream_socket_client
Mar 9, 2014
259e403
Example with certificate
Mar 9, 2014
55d31ad
suppress errors and warnings on connection creation, are handled by a…
Mar 18, 2014
e80db84
Make the connection timeout a default parameter of the constructor
Mar 27, 2014
60c9254
Added link to example
Mar 28, 2014
71697bd
replace flclose with stream_socket_shutdown
Apr 1, 2014
e3d5b6c
Merge branch 'master' of github.com:rethab/stomp-php
Apr 1, 2014
c51c793
added attempts parameter to constructor
Apr 1, 2014
ffc7d2b
shutdown stream for read and write
Apr 2, 2014
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 4 additions & 0 deletions README.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -52,6 +52,10 @@ Documentation

* [Web Site](http://stomp.fusesource.org/documentation/php/)

Step by Step: Certificate based Authentication
----------------------------------------------
https://github.com/rethab/php-stomp-cert-example

Tests
-----

Expand Down
15 changes: 12 additions & 3 deletions examples/first.php
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,5 +1,8 @@
<?php
require __DIR__.'/../vendor/autoload.php';
require __DIR__.'/../src/FuseSource/Stomp/Stomp.php';
require __DIR__.'/../src/FuseSource/Stomp/ExceptionInterface.php';
require __DIR__.'/../src/FuseSource/Stomp/Exception/StompException.php';
require __DIR__.'/../src/FuseSource/Stomp/Frame.php';
/**
*
* Copyright (C) 2009 Progress Software, Inc. All rights reserved.
Expand All @@ -22,7 +25,13 @@

use FuseSource\Stomp\Stomp;
// make a connection
$con = new Stomp("tcp://localhost:61613");
$opts = array(
'ssl' => array(
'local_cert' => './cachain.pem',
'passphrase' => 'bcop'
)
);
$con = new Stomp("ssl://localhost:61613", $opts);
// connect
$con->connect();
// send a message to the queue
Expand All @@ -44,4 +53,4 @@

// disconnect
$con->disconnect();
?>
?>
29 changes: 22 additions & 7 deletions src/FuseSource/Stomp/Stomp.php
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -66,27 +66,34 @@ class Stomp
protected $_socket = null;
protected $_hosts = array();
protected $_params = array();
protected $_ctx = null;
protected $_subscriptions = array();
protected $_defaultPort = 61613;
protected $_currentHost = - 1;
protected $_attempts = 10;
protected $_attempts = null;
protected $_username = '';
protected $_password = '';
protected $_sessionId;
protected $_read_timeout_seconds = 60;
protected $_read_timeout_milliseconds = 0;
protected $_connect_timeout_seconds = 60;
protected $_connect_timeout_seconds = null;
protected $_waitbuf = array();

/**
* Constructor
*
* @param string $brokerUri Broker URL
* @param array $opts options will be passed to stream_context_create and
* eventually be used to setup the connection. See the respective
* documentation on php.net on how to fill this array.
* @throws StompException
*/
public function __construct ($brokerUri)
public function __construct ($brokerUri, $opts = array(), $connect_timeout_seconds = 60, $attempts = 10)
{
$this->_brokerUri = $brokerUri;
$this->_ctx = stream_context_create($opts);
$this->_connect_timeout_seconds = $connect_timeout_seconds;
$this->_attempts = $attempts;
$this->_init();
}
/**
Expand Down Expand Up @@ -166,12 +173,20 @@ protected function _makeConnection ()
$port = $this->_defaultPort;
}
if ($this->_socket != null) {
fclose($this->_socket);
stream_socket_shutdown($this->_socket, STREAM_SHUT_RDWR);
$this->_socket = null;
}
$this->_socket = @fsockopen($scheme . '://' . $host, $port, $connect_errno, $connect_errstr, $this->_connect_timeout_seconds);

$this->_socket = @stream_socket_client(
$scheme.'://'.$host.':'.$port,
$connect_errno, $connect_errstr,
$this->_connect_timeout_seconds,
STREAM_CLIENT_CONNECT, $this->_ctx
);
if (!is_resource($this->_socket) && $att >= $this->_attempts && !array_key_exists($i + 1, $this->_hosts)) {
throw new StompException("Could not connect to $host:$port ($att/{$this->_attempts})");
throw new StompException("Could not connect to $host:$port
($att/{$this->_attempts}), ErrorCode $connect_errno, Reason:
$connect_errstr");
} else if (is_resource($this->_socket)) {
$connected = true;
$this->_currentHost = $i;
Expand Down Expand Up @@ -502,7 +517,7 @@ public function disconnect ()

if (is_resource($this->_socket)) {
$this->_writeFrame(new Frame('DISCONNECT', $headers));
fclose($this->_socket);
stream_socket_shutdown($this->_socket, STREAM_SHUT_RDWR);
}
$this->_socket = null;
$this->_sessionId = null;
Expand Down