Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Submit feedback
Sign in
Toggle navigation
A
AGRabbitMQ
Project
Project
Details
Activity
Releases
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Merge Requests
0
Merge Requests
0
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Commits
Open sidebar
Delivery
P
Public
Open source
AGRabbitMQ
Compare Revisions
004aa1989d081d4a254cd5d1d213156a80d7aff8...bb0a6f3495908198074f8db197ac8686b0da991d
Source
bb0a6f3495908198074f8db197ac8686b0da991d
Select Git revision
...
Target
004aa1989d081d4a254cd5d1d213156a80d7aff8
Select Git revision
Compare
Commits (2)
REFACTOR queue in uri
· 5b0995a8
dbourdere
authored
Apr 16, 2019
5b0995a8
Merge branch '5-rmq-queue-in-uri' into 'master'
· bb0a6f34
hlarget
authored
Apr 16, 2019
Resolve "RMQ queue in uri" Closes #5 See merge request open-source/agrabbitmq!6
bb0a6f34
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
10 additions
and
11 deletions
+10
-11
src/Client.php
src/Client.php
+8
-9
src/RMQConnector.php
src/RMQConnector.php
+2
-2
No files found.
src/Client.php
View file @
bb0a6f34
...
...
@@ -23,13 +23,13 @@ class Client
private
$login
;
private
$password
;
public
function
__construct
(
$address
=
"rabbitmq://guest:guest@localhost:5672/jakku"
)
public
function
__construct
(
$address
=
'rabbitmq://guest:guest@localhost:5672/jakku'
)
{
$url
=
Url
::
fromString
(
$address
);
if
(
filter_var
(
$address
,
FILTER_VALIDATE_URL
))
{
$userInfos
=
explode
(
":"
,
$url
->
getUserInfo
());
$this
->
channelName
=
ltrim
(
$url
->
getPath
(),
"/"
);
$userInfos
=
explode
(
':'
,
$url
->
getUserInfo
());
$this
->
channelName
=
ltrim
(
$url
->
getPath
(),
'/'
);
$this
->
address
=
$url
->
getHost
();
$this
->
port
=
$url
->
getPort
();
$this
->
login
=
$userInfos
[
0
];
...
...
@@ -37,12 +37,12 @@ class Client
}
}
public
function
connect
()
public
function
connect
()
:
void
{
$this
->
connection
=
new
AMQPStreamConnection
(
$this
->
address
,
$this
->
port
,
$this
->
login
,
$this
->
password
);
}
public
function
setConnection
(
$connection
)
public
function
setConnection
(
$connection
)
:
void
{
if
(
$connection
instanceof
AMQPStreamConnection
)
{
$this
->
connection
=
$connection
;
...
...
@@ -50,7 +50,6 @@ class Client
}
public
function
connectToChannel
(
$queue
=
''
,
$passive
=
false
,
$durable
=
false
,
$exclusive
=
false
,
...
...
@@ -58,12 +57,12 @@ class Client
)
{
$this
->
channel
=
$this
->
connection
->
channel
();
if
(
!
isset
(
$this
->
channelName
)){
$this
->
channelName
=
$queue
;
$this
->
channelName
=
'jakku'
;
}
return
$this
->
channel
->
queue_declare
(
$
queu
e
,
$passive
,
$durable
,
$exclusive
,
$auto_delete
);
return
$this
->
channel
->
queue_declare
(
$
this
->
channelNam
e
,
$passive
,
$durable
,
$exclusive
,
$auto_delete
);
}
public
function
send
(
$content
)
public
function
send
(
$content
)
:
bool
{
$msg
=
new
AMQPMessage
(
$content
,
[
'delivery_mode'
=>
AMQPMessage
::
DELIVERY_MODE_PERSISTENT
]);
$this
->
channel
->
basic_publish
(
$msg
,
''
,
$this
->
channelName
);
...
...
src/RMQConnector.php
View file @
bb0a6f34
...
...
@@ -16,10 +16,10 @@ class RMQConnector
{
if
(
self
::
$client
==
null
)
{
self
::
$client
=
new
Client
(
$config
[
"address"
]
??
"rabbitmq://guest:guest@127.0.0.1:5672"
$config
[
"address"
]
??
"rabbitmq://guest:guest@127.0.0.1:5672
/jakku
"
);
self
::
$client
->
connect
();
self
::
$client
->
connectToChannel
(
$config
[
"
queue"
]
??
"jakku"
,
$config
[
"
passive"
]
??
false
,
$config
[
"durable"
]
??
true
,
$config
[
"exclusive"
]
??
false
,
self
::
$client
->
connectToChannel
(
$config
[
"passive"
]
??
false
,
$config
[
"durable"
]
??
true
,
$config
[
"exclusive"
]
??
false
,
$config
[
"auto_delete"
]
??
false
);
}
return
self
::
class
;
...
...