| # Licensed to the Apache Software Foundation (ASF) under one |
| # or more contributor license agreements. See the NOTICE file |
| # distributed with this work for additional information |
| # regarding copyright ownership. The ASF licenses this file |
| # to you under the Apache License, Version 2.0 (the |
| # "License"); you may not use this file except in compliance |
| # with the License. You may obtain a copy of the License at |
| # |
| # http://www.apache.org/licenses/LICENSE-2.0 |
| # |
| # Unless required by applicable law or agreed to in writing, |
| # software distributed under the License is distributed on an |
| # "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| # KIND, either express or implied. See the License for the |
| # specific language governing permissions and limitations |
| # under the License. |
| |
| |
| # Example Usergrid Qakka Queue System Configuration |
| |
| #------------------------------------------------------------------------------ |
| # Usergrid Cassandra config |
| |
| ## (Make sure cassandra.hosts is set correctly) |
| |
| # Comma separated list of Cassandra hosts that this instance should use |
| cassandra.hosts=localhost |
| |
| # Name of keyspace to be used for queues and queue message payload data (must be replicated) |
| cassandra.keyspace.application=qakka_test_application |
| |
| # Name of keyspace to be used for per region queue messages (must not be replicated) |
| cassandra.keyspace.queue-message=qakka_test_queue_messages |
| |
| # Number of connections to maintain in connection pool |
| #cassandra.connections=30 |
| |
| # Timeout pooled connections after this time |
| cassandra.timeout.pool=20000 |
| |
| |
| #------------------------------------------------------------------------------ |
| # Usergrid Cluster Config |
| |
| ## (Make sure all of these are set correctly) |
| |
| usergrid.cluster_name=Test Cluster |
| |
| usergrid.cluster.hostname=localhost |
| |
| # Comma-separated list of regions |
| usergrid.cluster.region.list=us-east |
| |
| # The local region of this Qakka instance |
| usergrid.cluster.region.local=us-east |
| |
| # Comma-separated lists of cluster "seed" nodes each with format {region}:{hostname} |
| usergrid.cluster.seeds=us-east:localhost |
| |
| # Port used for cluster communications. |
| usergrid.cluster.port=3545 |
| |
| |
| #------------------------------------------------------------------------------ |
| # Authentication config |
| |
| queue.auth.enabled=true |
| |
| queue.auth.username=admin |
| |
| queue.auth.password=s3cr3t |
| |
| |
| #------------------------------------------------------------------------------ |
| # Queue System Config |
| |
| # (You probably don't need to change these values) |
| |
| # Must be true for Qakka |
| queue.standalone=true |
| |
| # Enable in memory cache for queue reads |
| queue.inmemory.cache=true |
| |
| # Number of actors for processing queue gets/reads |
| queue.num.actors=50 |
| |
| # Number of actors for processing queue sends |
| queue.sender.num.actors=100 |
| |
| # Number of actors for processing queue writes |
| queue.writer.num.actors=100 |
| |
| # Timeout any queue send that takes longer than |
| queue.send.timeout.seconds=5 |
| |
| # Timeout any queue get/read that takes longer than |
| queue.get.timeout.seconds=5 |
| |
| # Shard size for storing queue messages |
| queue.shard.max.size=400000 |
| |
| # Frequency to check for new shards needed |
| queue.shard.allocation.check.frequency.millis=1000 |
| |
| # Allocate new shards some time in advance of when they are to be used |
| queue.shard.allocation.advance.time.millis=200 |
| |
| # Only write shard counters after this number opf changes |
| queue.shard.counter.max-in-memory=100 |
| |
| # Only write message counters after this number of changes |
| queue.message.counter.max-in-memory=100 |
| |
| # On a queue get, wait some time for new messages to arrive |
| queue.long.polling.time.millis=2000 |