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
88e870720b
merge bug19250 into default
2008-10-30 14:10:55 +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
acd67e5e3b
merge bug19332 into default
2008-10-12 17:35:36 +01:00
04189c2322
Print error message when codegen cannot import json
2008-10-10 16:26:06 +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
e3c4c91087
Added queue.unbind method
2008-10-04 15:32:06 +01:00
05bfeee8c8
Fixed bug with case handling of queue:out/1, queue:head/1
2008-09-23 08:45:17 +01:00
53c2a7cc9a
Swallow spaces between key and value in frame headers.
2008-09-18 18:42:09 +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
ae35f745c0
Tweak README
2008-09-10 13:09:51 +01:00
8a9c268fcd
Changed nowait flag from true to false for queue.delete
2008-09-10 13:03:07 +01:00
f8936cbcbc
More ruby examples: broadcasting, unsubscribing
2008-09-09 13:36:11 +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
6309e8d93d
Added default field to consume
2008-09-07 14:31:44 +01:00
0a03379584
Removed license needed by json.py since it was removed
2008-09-04 18:30:14 +01:00
10364dec73
Removed json.py, it will be added as a dependency
2008-09-04 17:09:31 +01:00
28f82ebe55
Merge bug17070 into default
2008-08-28 09:39:33 +01:00
222c1cc208
correct a few defaults, based on Tony's comments
...
- there is no sensible default value for the reply-code in basic.return
- '*.reject' should default requeue to 'true' so we don't throw away
messages by default
2008-08-27 10:54:55 +01:00
c7bf3d841b
fewer defaults - based on Tony's feedback
...
- we consider MRDQ to be a mis-feature, so we shouldn't use defaults
that bring it into play
- it is illegal to bind to the default exchange, so we shouldn't make
that the default
- routing-keys should be specified in most cases, so no point having a
default of ""
- it makes no sense to have an empty queue name in 'deliver', and
'declare-ok'.
2008-08-27 10:22:00 +01:00
c5877ca42e
merge bug17070 into default
2008-08-26 20:48:28 +01:00
4648f344e5
squash tiny bug
2008-08-26 20:47:54 +01:00
876bff2356
add a few empty-table defaults
2008-08-26 20:29:54 +01:00
952435a1ff
more default values
...
also changed a few defaults to more sensible settings
2008-08-26 19:26:08 +01:00
196ae05011
added more default values
2008-08-26 15:11:18 +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
6dfff13f76
Apply Rui Lopes' patch for content-type headers.
...
I've slightly extended it for content-encoding.
2008-08-11 17:49:09 +01:00
17f516262e
unquote default values, so they became Python objects after JSON parsing
2008-08-08 15:35:11 +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
7db0ed1820
Notes (from Sean Treadway)
2008-07-16 11:10:07 +01:00
9f07fbbadc
Correct termination condition in Ruby examples
2008-07-16 11:09:30 +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
c7ca7d9be7
Migrate .hgignore from umbrella
2008-07-08 12:18:00 +01:00
91e36ab6e6
Adjust to life under the new umbrella.
2008-07-03 14:46:20 +01:00
a41fc5ad04
Migrate branch bug17070
2008-07-03 13:45:32 +01:00
5aa63a26a1
Initial commit, from repo-rebase-20080703121916_default (e96543d904a2)
2008-07-03 13:35:10 +01:00
53c9dc3928
Added extra wrapper calls to lib_amqp
2008-06-27 17:27:07 +01:00
2978359960
Since 18550 landed, the path is different
2008-06-26 12:32:14 +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
c62bbf6368
Support binding during SUBSCRIBE. (Thanks to Artur Bergman)
2008-06-16 16:39:29 +01:00
dc230745f0
Fixes to STOMP adapter that came out of some experiments I ran
...
after talking to Sean Treadway.
- make it log the start/stop of each connection
- ignore writer shutdown messages (this was making it not-send
amqp error messages in some circumstances) because we're both
writer and reader, and if the writer is being told to quit,
the reader will shortly follow
- don't send ERROR frames to client on {'EXIT',_Pid,normal},
because they're just noise. Normal exits are the way the
channel and/or buffering_proxy shut down when there's no
exceptional condition, and conversely whenever there's an
exceptional condition, a non-normal exit reason is given.
2008-06-01 22:08:38 +01:00
be90e8b4e7
Make the example actually *use* a durable declaration :-)
2008-06-01 20:54:15 +01:00
869f4db8a3
Apply Sean Treadway's patch.
2008-06-01 11:38:18 +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
31911b2e3e
Add README.
2008-05-07 16:53:20 +01:00
c1c4809f2f
Rename examples to be more OTP-convention-like
2008-05-06 12:50:00 +01:00
48480f4433
Add perl examples.
2008-05-05 02:55:35 +01:00
529ccdc95a
Use the erlang/rabbit source directory variable.
2008-05-01 11:53:29 +01:00
04c9a7019f
Avoid losing messages when the socket closes abruptly by calling
...
rabbit_channel:shutdown/1, which nicely processes all the pending work
before notifying us of channel closure.
2008-04-30 16:48:11 +01:00
7ceb19b1e4
Update to new type signatures.
2008-04-30 15:05:33 +01:00
ac84c959be
Simplify and remove delays in the cb-receiver program.
2008-04-29 18:21:36 +01:00
05ce41ebf1
Use string_guid instead of binstring_guid
2008-04-29 18:05:58 +01:00
df6b3869fe
Update to new 1.3.0 way of building gensyms/guids
2008-04-29 12:36:18 +01:00
421ec13e95
Carl Bourne's test cases
2008-04-29 12:36:02 +01:00
ffe62a1ce1
Change Makefile to point at new hg relative path for rabbitmq broker.
2008-04-29 12:35:28 +01: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
900991f41c
Use $(MAKE) instead of make.
2008-02-03 14:40:00 +00:00
5df958d632
Use -I to find rabbit hrl files, not include_lib
2008-02-01 23:17:16 +00:00
6e989c5ef5
Transactions were implemented a few revisions ago.
2008-02-01 21:56:30 +00:00
7938ac4c9d
Ignore .beam files.
2008-02-01 21:55:59 +00:00
7fb304dbf9
Create ebin before trying to compile
2008-02-01 18:14:24 +00:00
2fa07ed3ca
More cleanup from tailor
2008-02-01 18:10:59 +00:00
dfd885673c
Clean up after tailor's migration from darcs
2008-02-01 18:08:53 +00:00
80c8ed9379
[project @ Improve error reporting.]
2008-01-29 12:52:31 +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
534ec4a888
[project @ STOMP transactions.]
2007-12-21 13:50:26 +00:00
78e19793db
[project @ Make user header keys start with "X-".]
2007-12-21 13:49:30 +00:00
d02a209cb1
[project @ Take advantage of ok assertion on rabbit_channel:do]
2007-12-20 23:52:28 +00:00
088a772e10
[project @ Use new rabbit_channel:do API]
2007-12-20 23:38:05 +00:00
26f11efbc9
[project @ Follow Matthias' latest API change, removing channel numbers]
2007-12-20 23:13:10 +00:00
f0ea42f798
[project @ License information at the top of source files.]
2007-12-20 22:58:28 +00:00
9bb56d7abd
[project @ Comments and license information at the top of source files.]
2007-12-20 22:57:58 +00:00
7d86f8caa2
[project @ Implement tickets and synchronous channel open and ticket request.]
2007-12-20 22:55:18 +00:00
a766f3f867
[project @ Support DISCONNECT when not logged in]
2007-12-20 22:29:06 +00:00
35a00184f8
[project @ Moved from CVS mainline to separate repository.]
2007-12-20 22:26:13 +00:00
c47c599cd7
Tailor preparing to convert repo by adding .hgignore
2008-02-01 18:02:43 +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
Tony Garnock-Jones
Matthias Radestock
Hubert Plociniczak
Tony Garnock-Jones
Karol Skocik
0x6e6562
adrian@lshift.net
adrien@lshift.net
simon@lshift.net