diff options
| author | Matthias Radestock <matthias@lshift.net> | 2009-04-01 15:08:42 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2009-04-01 15:08:42 +0100 |
| commit | 074f16acbd597a51c941f716cdba9c20fca13153 (patch) | |
| tree | ff1c9a2e6baf9896d7d7c1a9c5946b1f71e8f013 /src/rabbit_persister.erl | |
| parent | e44b23cbcacc4d531c1a61209cdca870d966e682 (diff) | |
| download | rabbitmq-server-074f16acbd597a51c941f716cdba9c20fca13153.tar.gz | |
wait foreverbug20546
Diffstat (limited to 'src/rabbit_persister.erl')
| -rw-r--r-- | src/rabbit_persister.erl | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/rabbit_persister.erl b/src/rabbit_persister.erl index 99ae3f38..f4fa4599 100644 --- a/src/rabbit_persister.erl +++ b/src/rabbit_persister.erl @@ -95,7 +95,7 @@ start_link() -> transaction(MessageList) -> ?LOGDEBUG("transaction ~p~n", [MessageList]), TxnKey = rabbit_guid:guid(), - gen_server:call(?SERVER, {transaction, TxnKey, MessageList}). + gen_server:call(?SERVER, {transaction, TxnKey, MessageList}, infinity). extend_transaction(TxnKey, MessageList) -> ?LOGDEBUG("extend_transaction ~p ~p~n", [TxnKey, MessageList]), @@ -107,17 +107,17 @@ dirty_work(MessageList) -> commit_transaction(TxnKey) -> ?LOGDEBUG("commit_transaction ~p~n", [TxnKey]), - gen_server:call(?SERVER, {commit_transaction, TxnKey}). + gen_server:call(?SERVER, {commit_transaction, TxnKey}, infinity). rollback_transaction(TxnKey) -> ?LOGDEBUG("rollback_transaction ~p~n", [TxnKey]), gen_server:cast(?SERVER, {rollback_transaction, TxnKey}). force_snapshot() -> - gen_server:call(?SERVER, force_snapshot). + gen_server:call(?SERVER, force_snapshot, infinity). serial() -> - gen_server:call(?SERVER, serial). + gen_server:call(?SERVER, serial, infinity). %%-------------------------------------------------------------------- |