Allows multiple queues

.gitignore

@@ -10,3 +10,4 @@ build/
 *.mode2v3
 
 xcuserdata
+Project/DerivedData

EDQueue/EDQueue.h

@@ -39,9 +39,12 @@ UIKIT_EXTERN NSString *const EDQueueDidDrain;
 @property (weak) id<EDQueueDelegate> delegate;
 @property (readonly) Boolean isRunning;
 @property (readonly) Boolean isActive;
+@property (readonly) NSString *name;
 @property NSUInteger retryLimit;
 
 + (EDQueue *)sharedInstance;
++ (EDQueue *)queueNamed:(NSString *)name;
+
 - (void)enqueueWithData:(id)data forTask:(NSString *)task;
 
 - (void)start;

EDQueue/EDQueue.m

@@ -45,11 +45,20 @@ + (EDQueue *)sharedInstance
     });
 }
 
-- (id)init
++ (EDQueue *)queueNamed:(NSString *)name {
+  return [[self alloc] initWithName:name];
+}
+
+- (id)init {
+  return [self initWithName:nil];
+}
+
+- (id)initWithName:(NSString *)name
 {
     self = [super init];
     if (self) {
-        _engine     = [[EDQueueStorageEngine alloc] init];
+        _name       = name;
+        _engine     = [[EDQueueStorageEngine alloc] initWithName:self.name];
         _isRunning  = false;
         _isActive   = false;
         _retryLimit = 4;
@@ -233,7 +242,7 @@ - (void)processJob:(NSDictionary*)job withResult:(EDQueueResult)result
  */
 - (void)postNotification:(NSDictionary *)object
 {
-    [[NSNotificationCenter defaultCenter] postNotificationName:[object objectForKey:@"name"] object:[object objectForKey:@"data"]];
+    [[NSNotificationCenter defaultCenter] postNotificationName:[object objectForKey:@"name"] object:[object objectForKey:@"data"] userInfo:@{@"queue" : self.name?:@"default"}];
 }
 
 /**

EDQueue/EDQueueStorageEngine.h

@@ -16,7 +16,9 @@
 @interface EDQueueStorageEngine : NSObject
 
 @property (retain) FMDatabaseQueue *queue;
+@property (readonly) NSString *name;
 
+- (EDQueueStorageEngine *)initWithName:(NSString *)name;
 - (void)createJob:(id)data forTask:(id)task;
 - (Boolean)jobExistsForTask:(id)task;
 - (void)incrementAttemptForJob:(NSNumber *)jid;

EDQueue/EDQueueStorageEngine.m

@@ -12,14 +12,19 @@ @implementation EDQueueStorageEngine
 
 #pragma mark - Init
 
-- (id)init
+- (id)init {
+  return [self initWithName:nil];
+}
+
+- (EDQueueStorageEngine *)initWithName:(NSString *)name
 {
     self = [super init];
     if (self) {
         // Database path
+        _name                           = [NSString stringWithFormat:@"edqueue_%@.db", name?:@"0.5.0d"];
         NSArray *paths                  = NSSearchPathForDirectoriesInDomains(NSDocumentDirectory, NSUserDomainMask,YES);
         NSString *documentsDirectory    = [paths objectAtIndex:0];
-        NSString *path                  = [documentsDirectory stringByAppendingPathComponent:@"edqueue_0.5.0d.db"];
+        NSString *path                  = [documentsDirectory stringByAppendingPathComponent:self.name];
 
         // Allocate the queue
         _queue                          = [[FMDatabaseQueue alloc] initWithPath:path];