diff --git a/backends/ec2.go b/backends/ec2.go index 5a320fa3d7..d2e5433d50 100644 --- a/backends/ec2.go +++ b/backends/ec2.go @@ -1,6 +1,7 @@ package backends import ( + "time" "fmt" "github.com/docker/libswarm/beam" ) @@ -55,9 +56,15 @@ func (c *ec2Client) stop(ctx *beam.Message) error { func (c *ec2Client) attach(ctx *beam.Message) error { fmt.Println("*** ec2 OnAttach ***") ctx.Ret.Send(&beam.Message{Verb: beam.Ack, Ret: c.Server}) + + for { + time.Sleep(1 * time.Second) + (&beam.Object{ctx.Ret}).Log("ec2: heartbeat") + } return nil } + func Ec2() beam.Sender { backend := beam.NewServer() backend.OnSpawn(beam.Handler(func(ctx *beam.Message) error {