Heights,4102^3389354,2,2014-03-18 02:56:05,2014-03-18 03:04:24,N,1,-73.896995544433594,40.746292114257813,-73.890357971191406,40.739013671875,1,0.86,7,0.5,0.5,0,0,,,8,2,1,260,83,green,0.00,0.0,0.0,43,28,6.93,1291,263,4,Queens,026300,4026300,E,QN63,Woodside,4109,670,489,4,Queens,048900,4048900,E,QN50,Elmhurst-Maspeth,4109^3389355,1,2014-03-06 12:52:52,2014-03-06 13:32:34,N,1,-73.895805358886719,40.746040344238281,-73.952842712402344,40.788890838623047,2,6.50,30,0,0.5,2,0,,,32.5,1,,260,75,green,0.00,3.9,0.0,31,...

// along with this program.  If not, see <http://www.gnu.org/licenses/>.

package dsync

import (
	"context"
	"fmt"
	"runtime"
	"sync/atomic"
	"testing"
	"time"
)

const (
	id     = "1234-5678"
	source = "main.go"
)

func testSimpleWriteLock(t *testing.T, duration time.Duration) (locked bool) {
	drwm1 := NewDRWMutex(ds, "simplelock")
	ctx1, cancel1 := context.WithCancel(context.Background())

			Type:        "string",
			Sensitive:   true,
		},
	}

	HelpAMQP = config.HelpKVS{
		config.HelpKV{
			Key:         target.AmqpURL,
			Description: "AMQP server endpoint e.g. `amqp://myuser:mypassword@localhost:5672`",
			Type:        "url",
			Sensitive:   true,
		},
		config.HelpKV{
			Key:         target.AmqpExchange,
			Description: "name of the AMQP exchange",
			Optional:    true,
			Type:        "string",
		},

```
KEY:
notify_amqp[:name]  publish bucket notifications to AMQP endpoints

ARGS:
url*           (url)       AMQP server endpoint e.g. `amqp://myuser:mypassword@localhost:5672`
exchange       (string)    name of the AMQP exchange
exchange_type  (string)    AMQP exchange type
routing_key    (string)    routing key for publishing

4423, 4451, 4475, 4499, 4528, 4546, 4563, 4585, 4602, 4620, 4640, 4666, 4682, 4701, 4722, 4726, 4744, 4761, 4787, 4801, 4825, 4846, 4861, 4879, 4902, 4917, 4936, 4953, 4970, 4994, 5021, 5044, 5067, 5084, 5106, 5122, 5142, 5161, 5183, 5204, 5224, 5246, 5270, 5289, 5331, 5352, 5375, 5396, 5427, 5446, 5468, 5488, 5514, 5535, 5557, 5577, 5601, 5624, 5643, 5663, 5685, 5708, 5739, 5777, 5818, 5848, 5862, 5883, 5899, 5921, 5951, 5977, 6005, 6039, 6057, 6080, 6115, 6155, 6197, 6229, 6246, 6271, 6286, 6303, 6313,...