descriptionRabbitMQ Erlang AMQP client
ownerben@lshift.net
last changeMon, 15 Mar 2010 15:23:43 +1300
changes
2 days agoTony Garnock-JonesMerge bug21949 into default default tip
2 days agoTony Garnock-JonesPush down extraction of version from app descriptor bug21949
12 days agoMatthew SackmanMerging bug 21939 into default
12 days agoVlad Ionescuuser app can now use amqp_channel:cast with synchronous methods - this will log a warning saying that cast has been used with a synchronous method and that the user app will not get the reply from the broker bug22088
12 days agoMichael BridgenThe behaviour changed name (was bug22169).
12 days agoMatthew SackmanMerging bug 22169 into default
12 days agoVlad Ionescuadding amqp_connection:info_keys/{0,1} bug21939
2 weeks agoVlad Ionescufixing behaviour on invalid info atom bug21939
3 weeks agoMatthew Sackmanmerging default into bug 22169 bug22169
4 weeks agoMatthew SackmanMerging bug 21998 ⇨ default
4 weeks agoVlad Ionescuadditional client properties can now be supplied through #amqp_params bug21949
4 weeks agoVlad Ionescuthe direct connection can now get server_properties from the server and return them through amqp_connection:info/2 on request; renaming amqp_connection:infos/2 to amqp_connection:info/2 bug21939
4 weeks agoVlad Ionescuadding amqp_connection:infos/2, which can be used to get server_properties, which is now stored in the connection's state bug21939
4 weeks agoVlad Ionescujunking bug21939 junk
4 weeks agoVlad Ionescuadding c_ variants of the tracing functions; refactoring bug21998
4 weeks agoVlad Ionescucosmetic bug21998
5 weeks agoVlad Ionescuadding comments; changing lists:foreach to list comprehensions; other cosmetic bug21998
5 weeks agoMatthew SackmanMerging default into bug21673 bug21673
5 weeks agoMatthew SackmanMerging bug22254 into default
6 weeks agoVlad Ionescuadding tests for shortstr overflow bug22254
6 weeks agoMatthew SackmanMerging default into bug21673 bug21673
6 weeks agoVlad Ionescuadding test/amqp_dbg bug21998
7 weeks agoMichael BridgenCorrect what I hope was an accidental use of the tab character bug22169
7 weeks agoMichael BridgenMerge default into bug22169 bug22169
7 weeks agoMatthew SackmanMerged default into bug22056, inverting all the changes. However, I suspect the dies will still win if bug22056 ever is merged into default so care will still be needed bug22056
7 weeks agoMatthew SackmanBacked out the changes that were on branch bug22056
7 weeks agoVlad Ionescumerging bug21998 with junk junk
7 weeks agoVlad Ionescusome more small fixes bug22180
7 weeks agoVlad Ionescubetter explanations bug22180
7 weeks agoVlad Ionescumore general #amqp_error{} handling in channel process bug22180
7 weeks agoMatthew Sackmanmerging default into bug 22056 bug22056
7 weeks agoVlad Ionescuthe network connection now sends a 'connection.close' with code command_invalid if a heartbeat or a trace frame for a non-zero channel is received by the main reader bug22180
7 weeks agoVlad Ionescusome tests and some fixes bug22180
7 weeks agoVlad Ionescunetwork connection now sends connection.close with reason command_invalid when receiving unexpected methods on channel 0 bug22180
7 weeks agoVlad Ionescuusing rabbit_binary_generator:map_exception/2 rather than amqp_exception/1 bug22180
7 weeks agoVlad Ionescurefactoring the handling of channel exits to make use of rabbit_binary_generator:amqp_exception/1, formerly part of rabbit_reader:map_exception/2; renaming 'internal_error' connection closing reason to 'error' as it now includes the situation in which the server misbehaves and as a result, the client closes the connection; other related tweaks bug22180
7 weeks agoVlad Ionescubetter is_connection_method bug22180
8 weeks agoMatthew SackmanAdded rabbit_msg_store_index (which is a behaviour spec) to the common app bug21673
2 months agoMatthias Radestockmerge bug22090 into default
2 months agoVlad Ionescuterminating channel if received method starts with 'connection.'; internal_error_closing now accepts parameter in order to specify code and method; connection now sends code 503 when channel dies due to command_invalid bug22180
2 months agoVlad Ionescuminor comment bug22069
2 months agoVlad Ionescuadding broadcast_closing_if_abrupt, set_initial_closing and handle_open_channel to connection util to further remove duplication bug22069
2 months agoVlad Ionescucreating amqp_connection_util and gen_c_state mechanism for functions common to the network and direct types of connection; moving handle_exit to amqp_connection_util; moving check_trigger_channels_closed_event to amqp_connection_util; moving unregister_channel to amqp_connection_util; more refactoring to follow bug22069
2 months agoVlad Ionescufixing old example in comment bug22090
2 months agoDavid R. MacIverall of the changes made in this branch are superfluous. The branch can be trashed, but for clarity am reverting anyway bug21899
2 months agoMatthias Radestockpost-backout merge bug22169
2 months agoMatthias RadestockBacked out changeset 1c4cb3a06222 bug22169
2 months agoMatthias Radestockcreate branch for bug 22169 bug22169
2 months agoMatthias Radestockpost-backout merge
2 months agoMatthias RadestockBacked out changeset be841d4bfbb5
3 months agoDavid R. MacIverremove defaults from nc_state params fields, as they're never used bug21899
3 months agoDavid R. MacIverSSL tests passing and default port correct for ssl/normal bug21899
3 months agoDavid R. MacIverfix egregiously wrong default for nc_state#amqp_params. Somehow that passed through the test suite uncomplaining, which is a bit worrying. bug21899
3 months agoDavid R. MacIverbreak connection_params back out into amqp_params and tcp_params. direct connections only need amqp_params. All tests pass bug21899
3 months agoDavid R. MacIverinterim renaming of amqp_params to connection_params bug21899
3 months agoMatthew SackmanDon't put a trailing colon on ERL_LIBS if ERL_LIBS isn't defined
3 months agoVlad Ionescumerging bug22056 into default
3 months agoMatthias Radestockmerge bug22063 into default
3 months agoMatthias Radestockrefactoring in order to reduce code duplication bug22063
3 months agoVlad Ionescureplacing use of rabbit_framing:is_amqp_hard_error with rabbit_framing:lookup_amqp_exception(rabbit_framing:amqp_exception(..)) bug22063
3 months agoTony Garnock-JonesMerge heads of default
3 months agoVlad IonescuAdded tag rabbitmq_v1_7_0 for changeset 825eceaca84c
3 months agoVlad Ionesculogging process lifecycle debug messages bug21998
3 months agoMatthew SackmanRemove channel:subscribe totally, and instead make sure that channel:call(#'basic.consume'{}...) works correctly. The consume-ok is no longer sent. If you want to get another process to receive messages then send them the channel pid and get them to do the :call(#'basic.consume'{}...). This removes a wart from the API, removes a POA and makes things more consistent. bug22056
3 months agoMatthew Sackmanmerging bug 22049 into default
3 months agoVlad Ionescusetting insist = true in 'connection.open' bug22049
3 months agoMatthew SackmanAllow ERL_LIBS and ERL_PATH to be specified in either the env or as args to make to make it easier to specify additional directories to the various targets (make run is a good example)
3 months agoMatthew Sackmanmerging bug 21409 into default
3 months agoMatthew SackmanAdded a test. However, can't actually verify that the negotiation was correct as there's no way of getting the params back from the network process. Oh well. Test does pass. bug21409
3 months agoMatthew Sackmanmerging bug 22020 into default
3 months agoTony Garnock-JonesInclude exchange behaviour in common module bug22020
4 months agoVlad Ionescustoring server_properties in the network connection state record bug21939
4 months agoBen HoodAdded maximum negotiation and protocol version checking bug21409
4 months agoBen HoodMerged bug21619 into default
4 months agoBen HoodMerged default into bug21619 bug21619
4 months agoBen HoodMerged bug21880 into default
4 months agoBen HoodMerged default into bug21880 bug21880
4 months agoBen HoodMerged bug21775 into default
4 months agoBen HoodMerged default into bug21775 bug21775
4 months agoBen HoodFixed bug in the app descriptor rabbitmq_v1_7_0
4 months agoVlad Ionescuboth network and direct connection processes are now able to determine if error code sent by the server is either hard or soft and take appropriate action bug21775
4 months agoVlad Ionescufixing catch problem; increasing timeout for waiting for close_ok on connection close bug21619
4 months agoVlad Ionescubetter channel number choosing algorithm; using channel_max field in 'connection.tune' bug21619
4 months agoVlad Ionescumoving rpc server and client state records to their respective modules; adding rpc_test to the direct client suite as well bug21880
4 months agoVlad Ionescucosmetic bug21619
4 months agoVlad Ionescufixing performance issue in registering channel numbers bug21619
4 months agoBen HoodMerged bug21803 into default
4 months agoVlad Ionescuremoving an unecessary check; other cosmetic bug21803
4 months agoVlad Ionescumerging from default bug21803
4 months agoVlad Ionescusplitting amqp_connection; removing driver modules; adding module for main reader; adding amqp_channel_util module; all tests pass, need to review and test further, some code duplication to be removed bug21803
5 months agoVlad Ionescumerging from bug21698 bug21803
4 months agoBen HoodMerged bug21698 into default
5 months agoVlad Ionescufixing failing basic_qos_test bug21698
5 months agoVlad Ionescumerging from default bug21698
5 months agoBen HoodMerged bug21564 into default
5 months agoBen HoodMerged bug21783 into default
5 months agoVlad Ionescuremoving use of gen_event in return handler; trapping EXITs from handlers to unregister them bug21783
5 months agoVlad Ionescufixing output for test_common_package make target bug21564
5 months agoVlad Ionescufixing closing state overriding; other small fixes bug21698
5 months agoVlad Ionescumerging from default bug21698
5 months agoVlad Ionescumajor redesign of amqp_connection's closing mechanism bug21698
5 months agoMatthew SackmanLIBS_PATH is needed in run otherwise things like rr("include/amqp_client.hrl") refuse to work.
5 months agoBen HoodMerged bug21762 into default
5 months agoVlad Ionescuadding support for channel flushing and connection closing state in amqp_channel; fixing subscribe calls should be blocked if channel is closing; other cosmetic bug21698
5 months agoVlad Ionescumerging from bug21762 bug21698
5 months agoVlad Ionescumajor refactoring of amqp_channel's handling of messages bug21762
5 months agoBen HoodMerged bug21696 into default
5 months agoVlad Ionescuremoving leftover pattern for handle_cast bug21696
5 months agoVlad Ionescusetting closing flag in channel only when the 'channel.close' message actually gets sent to the server; ignoring all incoming traffic except 'channel.close' and 'channel.close_ok' when channel is closing; ignoring all further messages initiated by the application when channel is closing bug21696
5 months agoVlad Ionescumerging bug21695 into default
5 months agoMatthew Sackmanmerging in from bug 21714
5 months agoMatthias Radestockbump minimum OTP version for enabling dialyzer type specs bug21714
5 months agoBen HoodDrivers can now force a connection without sending a gen_server reply to anybody. The terminate callback in amqp_connection selectively sends a connection.close depending on why it itself is exiting. bug21695
5 months agoBen HoodMerged bug21172 into default
5 months agoBen HoodFixed spelling bug21172
5 months agoVlad Ionescurenaming channel_death_test to channel_writer_death_test; adding new channel_death_test, which can be run in both network and direct cases bug21172
5 months agoVlad Ionescuupdating from default bug21172
5 months agoVlad Ionescufixing missing return in handling other pid exit signal
5 months agoBen HoodMerged default into bug21172 bug21172
5 months agoMarek MajkowskiMerged bug 20399 into default
5 months agoVlad Ionescumerging from default bug20399
5 months agoVlad Ionescumerging bug21172v1 with junk junk
5 months agoVlad Ionescuan internal error in the channel process now takes the entire connection down bug21172
5 months agoVlad Ionescucommiting this only in case we ever change our mind. In this fix, the connection sends a fake channel.close on behalf of the channel and waits for channel.close_ok, or times out bug21172v1
5 months agoVlad Ionescumerging from default bug21172
6 months agoVlad Ionescumerging from default bug21172
5 months agoBen HoodMerged bug21618 into default
5 months agoVlad Ionescurefactoring handling of EXIT signals in amqp_connection; other cosmetic bug21618
5 months agoVlad Ionescufixing race condition between writer0 and main_reader exit signals; other small fixes bug21618
5 months agoVlad Ionescureader doesn't need trap_exit bug21618
5 months agoVlad Ionescudrivers must not be aware of channel_state (forgot about close_channel) bug21618
5 months agoVlad Ionescudrivers must not be aware of channel_state bug21618
5 months agoVlad Ionescutaking care of renamed field in #amqp_error{}; making naming of variables from amqp_error{} fields consistent bug20399
6 months agoVlad Ionescuchanging error reasons of type {amqp, ...} to #amqp_error{} bug20399
6 months agoVlad Ionescuremoving unnecessary relinking of writer process bug21618
6 months agoVlad Ionescuclosing rabbit framing channels properly bug21618
6 months agoVlad Ionescuframing channel is now started from the channel process and monitored by the main reader; refactoring exit trapping in amqp_connection; refactoring channel registration in amqp_connection bug21618
6 months agoVlad Ionescumerging from default bug21618
6 months agoVlad Ionescurefactoring open_channel: now mostly done in the channel process - simpler, more readable; refactoring of managing the framing channel to follow bug21618
6 months agoBen HoodMerged bug21616 into default
6 months agoVlad Ionescurefactoring framing channel registration in the reader process; handling socket_closed exit in amqp_channel separately; linking framing channel with reader bug21616
6 months agoVlad Ionescumerging bug21023 with junk junk
6 months agoVlad Ionescufixing dependencies in dialyzer-related make targets; fixing dependencies in compile_tests make targets bug21023
6 months agoBen HoodMerged bug21563 into default
6 months agoVlad Ionescurefactoring amqp_channel:rpc_top_half and rpc_bottom_half bug21563
6 months agoVlad Ionescumerging bug21533 into default
6 months agoVlad Ionescufixing merge conflict bug21533
6 months agoVlad Ionescuupdating from default bug21533
6 months agoVlad Ionescumerging bug21522 into default
6 months agoBen HoodQualified the exit from the channel0 process bug21522
6 months agoVlad Ionescufixing merge bug21023
6 months agoVlad Ionescumerging from default bug21023
6 months agoVlad Ionescufixing odd bug: when running make clean on broker, make compile in erlang client does not cause rebuilding of broker bug21023
6 months agoVlad Ionescuusing rabbit_dialyzer for dialysis; updating README bug21023
6 months agoVlad Ionescuremoving ERL_HOME variable; fixing call to broker makefile to create rabbit.plt bug21023
6 months agoBen HoodRefactored the channel registration in the connection process so that it reads better and allocates channel numbers in a more sensible fashion. channel processes that die on the client are trapped and the connection process just ignores them, i.e. the channel number is not de-allocated, because that would free up the channel number and hence confuse the server. This bug requires 21522 and 21533 to land before this can be seriously tested. bug21172
6 months agoBen HoodAdded shutdown statements to tests that were leaking processes bug21533
6 months agoVlad Ionescuimproved dialysis bug21023
6 months agoBen HoodIntroduced a closing state when the broker initiates the shutdown. This allows bug21522
6 months agoBen HoodJunked bug21522 junk
6 months agoMatthias Radestockerhm. > 5.7.0 is good enough
6 months agoMatthias Radestockmake type spec Erlang version constraint match that of the server Makefile
6 months agoBen HoodIgnoring socket close, wait for the connection process to exit by itself bug21522
6 months agoPaul JonesMerged bug21404 into default
6 months agoBen HoodMerged default into bug21404 bug21404
6 months agoBen Hoodsource tarball needs the app descriptor as well bug21311
6 months agoBen HoodMerged default into bug21311 bug21311
6 months agoBen HoodMinor tweak to get the app descriptor to get created
6 months agoBen HoodMerged default into bug21311 bug21311
6 months agoPaul JonesMerged bad second head of bug20869 into junk junk
6 months agoPaul JonesMerged bug21517 into default
6 months agoPaul JonesMerged bug21488 into default
6 months agoPaul JonesMerged bug21408 into default
6 months agoPaul JonesUpdated application descriptor to use RabbitMQ AMQP Client as the name
6 months agoPaul JonesMerged bug21515 into default
6 months agoPaul JonesFixed missing copy of the .hrl file bug21515
6 months agoPaul JonesAdded .app files to the ignore list bug21515
6 months agoBen HoodCall to channel.close now sets the closing flag bug21517
6 months agoBen HoodMerged default into 21311 bug21311
6 months agoBen Hood.app files now are generated by the Makefile bug21515
6 months agoBen HoodCherry picked old patch, now uses the app descriptor to get the version bug21408
6 months agoBen HoodJunked bug21408 junk
6 months agoBen HoodAdded client information bug21408
6 months agoBen HoodMerged default back into bug21488 bug21488
6 months agoBen HoodSomehow some io:formats got merged in from the SSL branch I think
6 months agoBen HoodMerged default into bug21488 bug21488
6 months agoBen HoodConnection level error in the direct case now is propagated to the channel process bug21488
6 months agoBen HoodBetter assertion about reason for channel closing bug21488
6 months agoBen HoodMerged bug21495 into default
6 months agoBen HoodMerged default into bug21495 bug21495
6 months agoBen HoodMerged default into bug21404 bug21404
6 months agoBen HoodCosmetic bug21488
6 months agoBen HoodCherry picked old version of bug21488 and applied it to reincarnation bug21488
6 months agoBen HoodJunked bug21488 junk
6 months agoBen HoodMerged default into bug21488 bug21488
6 months agoBen HoodMerged default into bug21311 bug21311
6 months agoMatthew Sackmanmerge in from bug 19356
6 months agoBen HoodMerged default into bug21311 bug21311
6 months agoBen HoodNow you can supply the path to the OTP dist that you want to build the client with bug21311
6 months agoMatthew Sackmanmerge in from default bug19356
...
tags
4 months agorabbitmq_v1_7_0
9 months agorabbitmq_v1_6_0
10 months agorabbitmq_v1_5_5
14 months agov1_5_1
...
branches
2 days agoeea6142b6845default
2 days agoec0c2e8f612fbug21949
12 days agoebafee514f53bug22088
12 days ago537320d7eb47bug21939
3 weeks agoeeda78bba07fbug22169
4 weeks agoab5dc9a0341bjunk
4 weeks agod9dcbcc748e5bug21998
5 weeks ago9cdc1fccd525bug21673
6 weeks ago006f54aa1a1abug22254
7 weeks ago5a3c3822e5b2bug22056
7 weeks agodc5dcce552afbug22180
2 months ago995d1dd03e8abug22069
2 months agobfa506ee8c84bug22090
2 months ago572d84ac7aa2bug21899
3 months ago8a2f59ffef81bug22063
3 months agod068c192433cbug22049
3 months ago84500c730243bug21409
3 months agob742830688a0bug22020
4 months agoc41c7cefa60bbug21619
4 months agoce41d495f5cfbug21880
4 months agoc6d33e515c40bug21775
4 months ago9f98aa81c617bug21803
5 months ago59ec3e0660abbug21698
5 months agofc3a4d0d4b7cbug21783
5 months agoae6b91be407abug21564
5 months ago03c91d685192bug21762
5 months ago3ac66a51b080bug21696
5 months ago9d9b1fc86852bug21714
5 months ago9343ca76242fbug21695
5 months ago23783f8f70b4bug21172
5 months ago0a02e171c8aebug20399
5 months agofd3edf6f1238bug21172v1
5 months ago242600a0040dbug21618
6 months agoc79617dacd0ebug21616
6 months agoef2b02c96547bug21023
6 months agobf6e4e3c68cebug21563
6 months agod08c75a79744bug21533
6 months ago120da68fe49dbug21522
6 months ago37b594587f1fbug21404
6 months agob2efec27f244bug21311
6 months agoe74ac1886c97bug21515
6 months agof357a2aadf40bug21517
6 months ago05d60439e902bug21408
6 months ago8783378103aabug21488
6 months agoc30c9ee93ceebug21495
6 months agod0eaea80b6a0bug19356
6 months ago9b74eb156996bug21493
6 months ago81d3d4bb7581bug19512
6 months agof2bdab91370ebug21306
6 months ago110046a310e3bug21309
6 months ago6ad03c790d88bug21455
7 months agob5e620378ba1bug21336
7 months ago2e55a8e42209bug20896
7 months agoe22f8e96d774bug21308
7 months ago13324fa34c16bug21407
7 months ago978f87b0aa41bug21419
7 months ago60929fdad8afbug21410
7 months agoccb07404bcc7bug21406
7 months agoa6f2b67f8f04bug21335
7 months ago12b378cf716abug21305
7 months ago9d7ee27cf4b2bug21234
7 months agodccbe4e445d2bug21156
7 months ago08530d23946cbug20539
7 months ago706ee7f7a73721234
7 months agob744825d449ebug21250
7 months ago0efd35004918bug21190
7 months ago63b777a0e6ddbug20915
8 months agocd423e749456bug19985
8 months ago076e09d8e805bug20937
8 months agobffa316d25d3bug20917
8 months ago7e72ec691da8bug19847
8 months agoea5ce3dd2b67bug20938
9 months agoa018efa144e8bug19911
9 months agoa46b48e3f982bug19357
9 months ago709b04dab74ebug19458
9 months ago67984ed21bb4v1_5
10 months agoea55ed0bb1cfbug20444
11 months ago3ac456258eb6bug20579
13 months ago39eb49dfe312bug20321
13 months ago1343623a6a86bug18557
14 months ago437d0e4d66c8bug20103
14 months ago6aec80b8a9b6bug19964
14 months agoef990be9ba9bbug19373
14 months ago4d2d87c05b26bug19625
14 months ago60db1bd04676bug19344
15 months ago4cf68655b043bug19560
15 months agoa9695aaf5083bug19963
15 months ago4bd0ad396224bug19395
16 months agod4adcc2f3c94bug19377
16 months ago08427ae99c43bug19251
16 months ago703268ee71a2bug19560_transplanted
16 months agoe1e00927c639bug19250
17 months ago9e046350b600bug19250_transplanted
17 months agoe91f6cbfa6dabug19432
18 months agoaf9e9b9d3966bug19131
18 months ago52c898cc148fbug19367
18 months ago2ee4e75d907cbug19334
20 months ago7d5021c0c7f4bug18994
...