f538cc3d98
Refactored read loop so that it handles a socket close explicitly
2009-01-06 15:49:37 +00:00
b409fa3c6c
Wait for peer to close socket, timeout if this doesn't occur
2009-01-06 14:54:00 +00:00
7d36c0c6a6
Merge with rabbitmq.com repo
2008-12-29 09:02:04 +01:00
4832d49d65
Update calls to rabbit_net:async_recv/3 to send in 'infinity' instead
...
of -1
2008-12-27 08:41:45 +01:00
919b1a3187
Rabbit's ssl socket is no more namespaced
2008-12-27 08:14:06 +01:00
4f4989ce13
Removed unecessary unsubscribe, replaced with channel close
2008-12-23 14:35:43 +00:00
6c6a68952d
RPC server closes channel when it terminates
2008-12-23 14:17:22 +00:00
53485d6c06
RPC client starts channel in init/1
2008-12-23 14:14:52 +00:00
ae742ea9fc
Client and server queues are now auto_delete and exclusive
2008-12-23 14:10:26 +00:00
075eacbb55
Implement ssl_client_test so we can have ssl makefile targets
...
Update hgignore
2008-12-21 00:13:05 +01:00
af7d7dab30
Deal with already_started crypto and ssl conditions.
2008-12-21 00:00:32 +01:00
441ef59ec2
Add clauses for creating ssl client connections.
...
- Implement start/6, start/7, start_link/6 and start_link/7.
These mimick the existing clauses, but take the extra parameters
Cacertfile, Certfile and Keyfile needed for a successfull SSL
connection setup.
2008-12-20 23:44:27 +01:00
e1d6ba5997
Add ssl support to the amqp_network_driver
...
- Refactor out do_handshake/2 from the handshake function.
- Implement handshake clauses, one for normal tcp connections
on port 5672 and one for upgraded ssl connections on port 5673
- seperate out TCP options into a MACRO so we can easily reuse it.
2008-12-20 23:40:19 +01:00
fb73ddff96
Extend the connection_state record to hold needed ssl info
...
cacertfile, certfile and keyfile
2008-12-20 23:14:05 +01:00
a3466fdf49
Replace all network calls with rabbit_net layer calls.
...
Ensure Make test_network still passes properly.
Add the softlinked rabbit_server folder to hgignore
2008-12-18 23:25:17 +01:00
e044b1610c
Merged default into 18557
2008-12-18 16:46:58 +00:00
778bc6d891
Merged default into 19344
2008-12-18 08:48:19 +00:00
baaf20f008
reformatting
2008-12-17 21:01:49 +00:00
7428cf693b
Fixed some QA remarks
2008-12-17 13:48:54 +00:00
a3b198799b
cosmetic
2008-12-11 07:15:20 +00:00
4400ba2094
Removed amqp_consumer module
2008-12-07 17:45:10 +00:00
de92adf9ef
Cosmetic
2008-12-07 16:44:29 +00:00
d5923bbad5
Tagged gen_server call to open_channel
2008-12-07 16:41:43 +00:00
935f540bb9
Got rid of unecessary string building
2008-12-07 16:37:10 +00:00
53836566ae
Removed unecessary flag
2008-12-07 16:31:42 +00:00
6577e354b8
Got rid of need to differentiate between network and direct
2008-12-07 16:30:34 +00:00
33d6b53a3a
Massaged module paramterization into something more manageable
2008-12-07 16:21:01 +00:00
0b2ef2b0b5
Merged 19625 into 19373
2008-12-07 15:16:26 +00:00
5cc6b90a3a
Cosmetic
2008-12-07 14:43:52 +00:00
48801f251c
Fixed compiler warning
2008-12-07 14:40:58 +00:00
3b8618d974
Merged 19344 into 19625
2008-12-07 14:40:00 +00:00
d0fb16d27e
RPC server does not have to be a process
2008-12-07 14:15:57 +00:00
2328e9c918
Incorporated some QA remarks
2008-12-07 13:57:52 +00:00
83194ea15f
Merged 19560 into 19344
2008-12-07 13:44:56 +00:00
f9e6d2913b
Somehow I forgot to reapply something from my patch stack
2008-12-07 13:28:21 +00:00
7c9e95b0aa
Refactored to make the flow test clearer
2008-12-07 13:18:32 +00:00
a4e103eb97
Fixed compiler warnings
2008-12-07 01:19:04 +00:00
ce36c34f77
Merged default into 18557
2008-12-07 01:16:45 +00:00
7ffdf4cc85
Gave consumer registration it's own API
2008-12-06 23:34:09 +00:00
612ae4248f
Got rid of compiler warnings
2008-12-05 00:24:51 +00:00
61f1313f66
Merged default into 19560
2008-12-05 00:21:51 +00:00
e1b0e40c6e
Merged default into 19344
2008-12-05 00:13:48 +00:00
9391a84b38
Savepoint
2008-12-04 11:04:44 +00:00
5e8619a103
add proper callback handlers
2008-11-29 01:30:28 +00:00
8ba334486b
Merged default into 18557
2008-11-24 00:27:58 +00:00
070026f2fc
Got rid of all of the compiler warnings
2008-11-24 00:03:45 +00:00
b235006d82
Merged bug 19377
2008-11-21 14:39:11 +00:00
cd5dd8be02
Fix typos
2008-11-21 14:38:54 +00:00
a61888b836
Fixed documentation
2008-11-21 14:28:57 +00:00
275e9329cb
Corrected the path to where rabbit logs
2008-11-20 17:57:18 +00:00
6e604526ac
Incorporated QA remarks
2008-11-20 17:51:27 +00:00
157007943b
Merged default into 18557
2008-11-20 14:38:45 +00:00
c2a63db846
fix typo
2008-11-19 20:52:32 +00:00
e0c0991f35
Added a test for qos, bit flakey but
2008-11-18 19:43:27 +00:00
ef6c448593
Squashed a whole lot of bugs
2008-11-14 14:04:25 +00:00
3238c878b9
Merged 19377 into 19344
2008-11-13 16:53:52 +00:00
2d21c5d7b5
Merged default into 19344, doesn't compile, but the answer is in 19377, but hg
...
doesn't multiple merges per commit
2008-11-13 16:41:22 +00:00
9fa1631953
Put the warning level up; this creates heaps of warnings, which should be fixed in a separate bug
2008-11-13 16:11:24 +00:00
ae1a3e8097
Refactored makefile
2008-11-13 16:09:27 +00:00
24520520c1
Merged default into 19251
2008-11-13 12:55:14 +00:00
d240a4996d
Added message handler for trapped exits
2008-11-13 12:50:19 +00:00
60025be500
Merged default into 19560
2008-11-12 23:56:45 +00:00
9b74a90635
Removed queueing from amqp_channel:call/3 because it could get quite dodgy.
...
If for example the application times out, the messages will get silently get sent to the broker and the application will be none the wiser.
2008-11-12 23:35:29 +00:00
7952b2743e
Added unit test for channel flow
2008-11-12 23:05:23 +00:00
f7391f1cf5
Added publish call
2008-11-12 19:17:22 +00:00
26cd77cc37
First cut at handling channel.flow in the Erlang client
2008-11-09 22:19:18 +00:00
6c1106d5ca
Added close handler to network driver
2008-10-27 16:15:19 +00:00
2076ae22ba
Started work on this bug, might need to add callback handlers
...
in the driver modules to propagted this properly.
2008-10-27 12:00:55 +00:00
ee541db2ac
cosmetic
2008-10-15 12:15:28 +01:00
00ca078719
Got rid of unecessary queue:is_empty
2008-10-15 11:39:07 +01:00
3af3be50fe
Adjusted some of the exit reasons
2008-10-09 11:37:02 +01:00
f1aee7cbec
Incorporated some QA remarks, added a test for this patch
2008-10-08 16:19:17 +01:00
56c0656f03
Added test for queue.unbind
2008-10-04 15:33:39 +01:00
05bfeee8c8
Fixed bug with case handling of queue:out/1, queue:head/1
2008-09-23 08:45:17 +01:00
324f094db8
Merged default into 19357
2008-09-15 11:08:20 +01:00
0e5184ab11
Merged default into 19251
2008-09-15 11:02:43 +01:00
bbc32c42f9
Grepped occurances of tickets
2008-09-11 13:01:52 +01:00
cb8cc4fccb
Grepped the source code for references to realms and removed them
2008-09-11 12:53:00 +01:00
4cfef5ba7e
Commented correct export statements back into the connection module
2008-09-10 23:38:16 +01:00
9037d4cbb2
Applied Edwin's first patch without any modifications
2008-09-10 23:30:14 +01:00
6f40756e7f
Removed tickets and realms
2008-09-10 13:20:17 +01:00
8a9c268fcd
Changed nowait flag from true to false for queue.delete
2008-09-10 13:03:07 +01:00
299b71265b
Streamlined the client, got it to a compilable state
2008-09-07 23:53:39 +01:00
52d606572e
Backed out changeset fed30851870b
2008-09-07 16:19:44 +01:00
c6dcf89ee9
Added better handling for when the other peer closes the socket
2008-09-07 16:07:52 +01:00
94829f1c3b
Removed setting tickets to 1 in lib_amqp
2008-09-07 14:42:17 +01:00
d704b63cb7
Removed Tabs
2008-08-25 11:05:03 +01:00
8932b72d1b
Removed access request, set tickets to 1, more consistent usage of lib_amqp
2008-08-20 12:00:25 +01:00
4c77e27bb3
merge changes erroneously committed against bug18944 into bug19131
2008-08-14 11:30:19 +01:00
a7845bd6db
Added missing target to makefile
2008-08-01 11:05:56 +01:00
62ac9f81b7
Fixed confusing comment
2008-07-30 23:17:44 +01:00
96e6504c9d
Removed call to non-existent function in rabbit_multi
2008-07-14 17:07:19 +01:00
1d1af7dabf
Removed the transmission of the access request command in the test setups
2008-07-13 19:53:44 +01:00
49307edfa2
Backed out changeset 35cf4476380c
2008-07-13 14:25:14 +01:00
1e0e4bdfe9
Started work on removing tickets and realms, but this work may have to depend on bug17070
2008-07-13 14:02:03 +01:00
53c9dc3928
Added extra wrapper calls to lib_amqp
2008-06-27 17:27:07 +01:00
fb2b4e52d6
Differentiates between hard and soft errors in the connection process
2008-06-25 10:18:45 +01:00
a55b60e3ba
Fix for bug when you try to publish to a non-existent exchange that crashes the connection, network case
2008-06-25 09:01:32 +01:00
b5e209b4f8
Fix for bug when you try to publish to a non-existent exchange that crashes the connection
2008-06-25 00:11:52 +01:00
ddb6cf6d00
Fixed type arguments in call to exit()
2008-06-23 11:30:53 +01:00
41ba30afc9
Ignore .beam files
2008-06-17 13:09:53 +01:00
25463a5472
Remove tailor detritus
2008-06-17 13:08:20 +01:00
1b5f11cba2
Subscription RPC requests now use the standard top-half/bottom-half mechanism
2008-05-15 11:22:47 +00:00
73960b4e0a
Linked network writer pid to channel process
2008-05-15 09:40:35 +00:00
fe61df8970
Converted tabs to spaces
2008-05-12 22:02:20 +00:00
b06baa9ecf
Fix for bug in request queuing that assumed commands could be pipelined
2008-05-12 21:41:12 +00:00
3da6b6cc2e
Made reader loop tail recursive
2008-05-12 20:39:48 +00:00
8ea9dde2b0
Channel Writer process is now shutdown in the network case
2008-05-12 20:31:22 +00:00
2a20c05029
Subscriptions can now be requested concurrently
2008-05-12 18:02:16 +00:00
00f52e9b86
Synchronous RPC requests are now queued up and dispatched serially
2008-05-09 22:55:14 +00:00
95ea5768f0
Bug fix that failed to detect multiple synchronous RPC requests
2008-05-08 19:13:51 +00:00
8a8a634590
"${ERLCALL} -q" to quit in Makefile
2008-02-21 11:36:29 +00:00
c28c9962d2
Better Makefile
2008-02-21 11:31:21 +00:00
7ab8df3848
Makefile fix, part 2 bis (no change in code though)
2008-02-20 17:15:57 +00:00
4659dc5afe
Makefile fix, part 2
2008-02-20 16:29:02 +00:00
1aa5e4317d
Makefile fix and bug 17806
2008-02-20 13:26:25 +00:00
82dc596575
Bug fix for connection close
2008-01-18 22:41:46 +00:00
686cc95711
Removed unnecessary function
2008-01-18 18:46:10 +00:00
85bfcbcd7e
Fix for strange handling of connection end
2008-01-18 18:40:10 +00:00
19c43c1eea
Added handling of the heartbeat timeout to the reader process
2008-01-18 09:42:53 +00:00
a35b50d5f5
Fixed exit trap between reader and framing channel process
2008-01-17 19:35:25 +00:00
e6998c6f43
Fixed trap exit handling when channel closing is not followed by a connection close
2008-01-17 18:51:38 +00:00
418b19101f
Passing connection pid to handshake is unecessary
2008-01-17 07:14:54 +00:00
d09ddc1c69
Removed unused frame unmarshalling code
2008-01-17 07:04:21 +00:00
2b03c85539
Used refactored start_link API in rabbit_framing_channel and refactored the tcp read loop
2008-01-16 22:26:05 +00:00
15efa37bf0
Added rabbit_framing_channel as an intermediary for unmarshalling frames from the wire
2008-01-11 13:23:21 +00:00
e498b483f7
Deleted print statement
2008-01-10 21:41:09 +00:00
6c5b7e09de
Added test for basic recover
2008-01-10 21:37:51 +00:00
cb993bd2c1
Changed the structure of a basic deliver that is sent to final consumer, added basic reject but left it commented out because the server does not handle it
2008-01-10 19:37:20 +00:00
fcde4c82ca
Added assertion for basic get empty
2008-01-10 18:02:11 +00:00
e7014721d4
Added return handler for basic returns
2008-01-10 12:04:16 +00:00
bf19763ea2
Added test for Basic.Return
2008-01-09 23:14:16 +00:00
a308a6a3ae
Ditched next_delivery_tag
2008-01-09 08:57:42 +00:00
0940e6366a
Removed acknowledgement message and implemented AMQP method on merit basis
2008-01-09 00:27:19 +00:00
00f6419397
Removed unecessary tx setting
2008-01-07 17:46:31 +00:00
ede426c0b0
Cleaned up a lot of commented out code, print statements
2008-01-06 22:39:41 +00:00
5a821f018c
Upgraded to rabbit 200712231445 snapshot
2008-01-06 22:05:00 +00:00
7b0e9090f5
Moved rabbit management stuff to separate module
2008-01-02 18:40:21 +00:00
dcc3b18810
Upgraded hessian version to 0.2.2, last version before management split out
2007-12-31 00:59:50 +00:00
5ac519da5a
Changed rpc_handler from gen_event to gen_server
2007-12-13 09:50:17 +00:00
316659533d
Fixed bug in init() of supervised event handler
2007-12-11 22:10:37 +00:00
0e68ca1411
Added supervisor behaviour for management
2007-12-10 23:26:40 +00:00
a8dd139a74
Added patch for java client
2007-12-03 10:44:14 +00:00
b0b8cc3522
Added java interface to the rabbit_access_control module
2007-12-03 00:08:13 +00:00
67a3301484
Exception handling for rabbit management
2007-11-06 10:38:39 +00:00
2771cc5efa
Bug 17356: Add copyright headers since they're currently lacking
2007-10-29 13:33:02 +00:00
5b4b862df1
Bug 17356: Added simple tarball target.
2007-10-29 12:02:58 +00:00
e613d9d15f
Updated README
2007-10-27 20:44:22 +00:00
6fb4a6dc91
First cut of exposing rabbit_access_control via AMQP
2007-10-27 20:41:37 +00:00
2664714d74
Fix for notify_sent bug
2007-10-22 07:46:31 +00:00
0477582492
Bug 17141: Clean up.
2007-10-18 14:57:31 +00:00
317738ed12
Bug 17141: Allow running the direct tests from the Makefile. This
...
requires rabbitmq server from CVS HEAD (i.e. >1.2.0). See the bug for
more discussion.
2007-10-18 14:53:24 +00:00
f4525ea336
merge of '0e53ebaee463865755981a06f200b7fce3a65534'
...
and '7941af4b3c4d5de328a342abdcc3513bf8221949'
2007-10-17 22:53:51 +00:00
458cb35e53
bug 17118: cosmetic changes to README
...
also improved prerequisites instructions
2007-10-10 12:35:47 +00:00
7241445b0b
Initial version of the Rpc client
2007-10-17 22:52:52 +00:00
f704f5c112
Introduced integration tests
2007-10-08 08:16:23 +00:00
56732fe069
Renamed test modules to allow split into unit and integration tests
2007-10-08 08:07:58 +00:00
443e3fffa2
Rebased off 200710071940 snapshot, removed patch and rabbit_direct_channel, handles set_transaction messages from rabbit_channel
2007-10-07 23:49:34 +00:00
f0cc017b92
Refactored RPC client state
2007-10-07 22:59:00 +00:00
be108080e7
Added comment about eunit in README
2007-10-06 18:54:52 +00:00
f918e3913b
Support for transactions in direct channel
2007-10-06 18:15:30 +00:00
77474d680e
Merged rpc test into files moved from test to src
2007-10-04 21:48:00 +00:00
bf7b99646a
merge of '75439caf7c745bc30810d141d45c5d8d413f9779'
...
and 'b3086899c0c2c062b46ab2983a5198163887697e'
2007-10-04 10:38:20 +00:00
4da5d3047f
Bug 17141: Add test coverage checking. Necessitates moving all erlang
...
files to src/.
2007-10-03 16:13:53 +00:00
a642aad923
merge of '17bbed595128dcb0ebbc27ca60eadfa2dfafdeb0'
...
and '36e2647276522b817bc64882227180142d188720'
2007-10-03 16:08:34 +00:00
4713212b04
disapproval of revision '18de103015dd6f8e87c4165b0fa8381319169cf2'
2007-10-03 16:08:21 +00:00
267f95b59c
Bug 17118: Add test coverage checking. Needed to move all the test code into
...
src/ to do this as the cover library only looks for source in src/.
2007-10-02 14:29:03 +00:00
635736c19b
Bug none: Moving rpc handler to permit merging
2007-10-04 10:38:12 +00:00
acb8aa9fea
Added initial test for rpc handling
2007-10-03 21:44:46 +00:00
c6ae835f6c
bug none: minor code cleanup
2007-10-02 09:35:28 +00:00
59aa485693
Bug 17118: Create ebin directory if it doesn't already exist.
2007-10-01 16:46:14 +00:00
e2b6b74355
Bug 17118: s/rabbit/rabbitmq_server/ to find header files.
2007-10-01 16:44:56 +00:00
24f7bb3da9
Bug 17118: Make server startup stuff more accurate.
2007-10-01 16:44:20 +00:00
ed17bbf119
Changed rpc/send to call/cast
2007-10-01 07:54:54 +00:00
8028772f35
Added README
2007-09-30 21:59:10 +00:00
d83dba2615
Separated amqp_client from the rabbit tree
2007-09-30 19:52:07 +00:00
ad7329aad1
Initial checkin
2007-09-13 16:06:53 +00:00
15a3189eba
Tailor preparing to convert repo by adding .hgignore
2008-06-17 12:46:32 +01:00
Ben Hood
Essien Ita Essien
Essien Ita Essien
Matthias Radestock
Simon MacMullen
Hubert Plociniczak
Tony Garnock-Jones
0x6e6562
adrian@lshift.net
adrien@lshift.net