diff --git a/lib/cap-ec2/capistrano.rb b/lib/cap-ec2/capistrano.rb
index 9df98ce..e2c0f96 100644
--- a/lib/cap-ec2/capistrano.rb
+++ b/lib/cap-ec2/capistrano.rb
@@ -19,9 +19,10 @@ def ec2_handler
       end
 
       def ec2_role(name, options={})
-        ec2_handler.get_servers_for_role(name).each do |server|
-          env.role(name, CapEC2::Utils.contact_point(server),
-                   options_with_instance_id(options, server))
+        ec2_handler.get_servers_for_role(options.fetch(:roles, name)).each do |roles, servers|
+          servers.each do |server|
+            env.role(name, CapEC2::Utils.contact_point(server), options_with_instance_id(options, server, roles))
+          end
         end
       end
 
@@ -31,8 +32,8 @@ def env
 
       private
 
-      def options_with_instance_id(options, server)
-        options.merge({aws_instance_id: server.instance_id})
+      def options_with_instance_id(options, server, extra_roles)
+        options.merge({aws_instance_id: server.instance_id, extra_roles: Array(extra_roles).map(&:to_sym)})
       end
 
     end
diff --git a/lib/cap-ec2/ec2-handler.rb b/lib/cap-ec2/ec2-handler.rb
index 2d54887..2d837a0 100644
--- a/lib/cap-ec2/ec2-handler.rb
+++ b/lib/cap-ec2/ec2-handler.rb
@@ -22,28 +22,28 @@ def ec2_connect(region=nil)
 
     def status_table
       CapEC2::StatusTable.new(
-        defined_roles.map {|r| get_servers_for_role(r)}.flatten.uniq {|i| i.instance_id}
+        defined_roles.map {|r| get_servers_for_role(r).values }.flatten.uniq {|i| i.instance_id}
       )
     end
 
     def server_names
-      puts defined_roles.map {|r| get_servers_for_role(r)}
-                   .flatten
-                   .uniq {|i| i.instance_id}
-                   .map {|i| i.tags["Name"]}
-                   .join("\n")
+      puts defined_roles.map {|r| get_servers_for_role(r).values }
+                  .flatten
+                  .uniq {|i| i.instance_id}
+                  .map {|i| i.tags["Name"]}
+                  .join("\n")
     end
 
     def instance_ids
-      puts defined_roles.map {|r| get_servers_for_role(r)}
-                   .flatten
-                   .uniq {|i| i.instance_id}
-                   .map {|i| i.instance_id}
-                   .join("\n")
+      puts defined_roles.map {|r| get_servers_for_role(r).values }
+                  .flatten
+                  .uniq {|i| i.instance_id}
+                  .map {|i| i.instance_id}
+                  .join("\n")
     end
 
     def defined_roles
-      roles(:all).flat_map(&:roles_array).uniq.sort
+      roles(:all).flat_map {|i| i.roles_array | (i.properties.extra_roles || []) }.uniq.sort
     end
 
     def stage
@@ -54,24 +54,44 @@ def application
       Capistrano::Configuration.env.fetch(:application).to_s
     end
 
+    def filter
+      f = Capistrano::Configuration.env.fetch(:ec2_filter)
+      f.respond_to?(:call) ? f.call : f
+    end
+
+    def default_filter
+      { tag(project_tag) => "*#{application}*" }
+    end
+
     def tag(tag_name)
       "tag:#{tag_name}"
     end
 
-    def get_servers_for_role(role)
-      servers = []
-      @ec2.each do |_, ec2|
-        instances = ec2.instances
-          .filter(tag(project_tag), "*#{application}*")
-          .filter('instance-state-name', 'running')
-        servers << instances.select do |i|
-          instance_has_tag?(i, roles_tag, role) &&
-            instance_has_tag?(i, stages_tag, stage) &&
-            instance_has_tag?(i, project_tag, application) &&
-            (fetch(:ec2_filter_by_status_ok?) ? instance_status_ok?(i) : true)
+    def get_servers_for_filter(filter)
+      @ec2.flat_map do |_, ec2|
+        instances = ec2.instances.filter('instance-state-name', 'running')
+        filter.each {|key, val| instances = instances.filter(key.to_s, *Array(val).map(&:to_s)) }
+        instances.to_a
+      end
+    end
+
+    def get_servers_for_role(roles)
+      servers = get_servers_for_filter(filter || default_filter).
+                  sort_by {|s| s.tags["Name"] || ''}.select do |i|
+                    instance_has_tag?(i, roles_tag, roles) &&
+                      (filter ||
+                        instance_has_tag?(i, stages_tag, stage) &&
+                        instance_has_tag?(i, project_tag, application)
+                      )
+                  end
+      servers.each_with_object({}) do |server, role_map|
+        matching_roles = instance_tags_matching(server, roles_tag, roles)
+        if matching_roles.any?
+          if !fetch(:ec2_filter_by_status_ok?) || instance_status_ok?(server)
+            (role_map[matching_roles] ||= []) << server
+          end
         end
       end
-      servers.flatten.sort_by {|s| s.tags["Name"] || ''}
     end
 
     def get_server(instance_id)
@@ -82,8 +102,13 @@ def get_server(instance_id)
 
     private
 
-    def instance_has_tag?(instance, key, value)
-      (instance.tags[key] || '').split(',').map(&:strip).include?(value.to_s)
+    def instance_has_tag?(instance, key, values)
+      instance_tags_matching(instance, key, values).any?
+    end
+
+    def instance_tags_matching(instance, key, values)
+      tags_array = (instance.tags[key] || "").split(',').map(&:strip)
+      tags_array & (Array(values).map(&:to_s))
     end
 
     def instance_status_ok?(instance)
diff --git a/lib/cap-ec2/status-table.rb b/lib/cap-ec2/status-table.rb
index 6f338f7..57c10bf 100644
--- a/lib/cap-ec2/status-table.rb
+++ b/lib/cap-ec2/status-table.rb
@@ -1,12 +1,12 @@
 module CapEC2
   class StatusTable
     include CapEC2::Utils
-    
+
     def initialize(instances)
       @instances = instances
       output
     end
-    
+
     def header_row
       [
         bold("Num"),
@@ -14,12 +14,13 @@ def header_row
         bold("ID"),
         bold("Type"),
         bold("DNS"),
+        bold("Internal"),
         bold("Zone"),
         bold("Roles"),
         bold("Stages")
       ]
     end
-    
+
     def output
       table = Terminal::Table.new(
         :style => {
@@ -42,6 +43,7 @@ def instance_to_row(instance, index)
         red(instance.id),
         cyan(instance.instance_type),
         bold(blue(CapEC2::Utils.contact_point(instance))),
+        bold(blue(instance.private_ip_address)),
         magenta(instance.availability_zone),
         yellow(instance.tags[roles_tag]),
         yellow(instance.tags[stages_tag])