diff options
| -rw-r--r-- | src/rabbit.erl | 4 | ||||
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 2 | ||||
| -rw-r--r-- | src/rabbit_disk_queue.erl | 2 |
3 files changed, 4 insertions, 4 deletions
diff --git a/src/rabbit.erl b/src/rabbit.erl index c0d09547c5..5062e7e986 100644 --- a/src/rabbit.erl +++ b/src/rabbit.erl @@ -157,8 +157,8 @@ start(normal, []) -> end}, {"disk queue", fun () -> - ok = start_child(rabbit_disk_queue), - ok = rabbit_disk_queue:to_ram_disk_mode() %% TODO, CHANGE ME + ok = start_child(rabbit_disk_queue) %%, + %% ok = rabbit_disk_queue:to_ram_disk_mode() %% TODO, CHANGE ME end}, {"guid generator", fun () -> diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 3ca88aaad6..5a8bd4a43d 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -92,7 +92,7 @@ start_link(Q) -> init(Q = #amqqueue { name = QName }) -> ?LOGDEBUG("Queue starting - ~p~n", [Q]), - {ok, MS} = rabbit_mixed_queue:start_link(QName, mixed), %% TODO, CHANGE ME + {ok, MS} = rabbit_mixed_queue:start_link(QName, disk), %% TODO, CHANGE ME {ok, #q{q = Q, owner = none, exclusive_consumer = none, diff --git a/src/rabbit_disk_queue.erl b/src/rabbit_disk_queue.erl index a0bc1bfdd6..8fb5b90505 100644 --- a/src/rabbit_disk_queue.erl +++ b/src/rabbit_disk_queue.erl @@ -63,7 +63,7 @@ -define(SERVER, ?MODULE). -define(MAX_READ_FILE_HANDLES, 256). --define(FILE_SIZE_LIMIT, (25*1024*1024)). +-define(FILE_SIZE_LIMIT, (256*1024*1024)). -record(dqstate, {msg_location_dets, %% where are messages? msg_location_ets, %% as above, but for ets version |