Skip to content

Commit

Permalink
Merge pull request #2 from cinterloper/de-ja-vu
Browse files Browse the repository at this point in the history
re-remove
  • Loading branch information
cinterloper committed Mar 24, 2016
2 parents 83b5f4f + fb80a1d commit 46e56cb
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -6,21 +6,18 @@ import io.vertx.core.json.JsonObject
import io.vertx.core.logging.Logger
import io.vertx.core.logging.LoggerFactory
import io.vertx.groovy.core.eventbus.EventBus
import io.vertx.groovy.core.shareddata.SharedData
import net.iowntheinter.saltReactor.SVXSubscriptionManager

/**
* Created by grant on 11/5/15.
*/
class SimplePipeSubscriptionManager implements SVXSubscriptionManager {
private SharedData sd
private EventBus eb
private Logger log
private subscriptionChannel
private SaltClient saltClient

SimplePipeSubscriptionManager(SharedData s, EventBus e, SaltClient c) {
sd = s
SimplePipeSubscriptionManager(EventBus e, SaltClient c) {
eb = e
log = LoggerFactory.getLogger("saltReactor:subscriptionManager")
saltClient = c
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,6 @@ import com.suse.salt.netapi.event.EventListener
import io.vertx.core.logging.Logger
import io.vertx.core.logging.LoggerFactory
import io.vertx.groovy.core.eventbus.EventBus
import io.vertx.groovy.core.shareddata.SharedData
import com.suse.salt.netapi.datatypes.Event;
import io.vertx.groovy.core.Vertx;
import io.vertx.core.json.JsonObject
Expand All @@ -18,7 +17,6 @@ import javax.websocket.CloseReason;

class saltReactor implements EventListener {
private Vertx vx
private SharedData sd
private EventBus eb
private JsonObject config
private Logger log
Expand All @@ -28,11 +26,10 @@ class saltReactor implements EventListener {
saltReactor(Vertx v, JsonObject c, SaltClient s) {
vx = v;
sc = s
sd = v.sharedData()
config = c
eb = v.eventBus()
log = LoggerFactory.getLogger("saltReactor")
mgr = new SimplePipeSubscriptionManager(sd, eb, sc)
mgr = new SimplePipeSubscriptionManager( eb, sc)
}
CloseReason closeReason;

Expand Down

0 comments on commit 46e56cb

Please sign in to comment.