global class TaskFromEmail implements Messaging.InboundEmailHandler
{
 global Messaging.InboundEmailResult handleInboundEmail(Messaging.inboundEmail email,
                 Messaging.InboundEnvelope env) 
 {
  Messaging.InboundEmailResult emailResult = new Messaging.InboundEmailResult();
  String myPlainText = '';
  myPlainText = email.plainTextBody;
  Task[] newTask = new Task[0];
  String[] userEmailAddress = new String[2];
  User myUser = null;
  
  if (myPlainText.contains('#')) 
  {
   userEmailAddress = myPlainText.split('#', 2);
   System.debug('##### ' + userEmailAddress[1] + ' #####');
  } 
  
  
  try
  {
   Contact myContact = [SELECT Id, Name, Email
      FROM Contact
      WHERE Email = :email.fromAddress
      LIMIT 1];      
   myUser = [SELECT Id, Email
       FROM User
       WHERE Email = :userEmailAddress[1]
       //WHERE Email = :email.subject
       LIMIT 1];        
              
   newTask.add(new Task(Description = userEmailAddress[0],
              Priority = 'Normal',
        Status = 'Inbound Email',
        Subject = email.subject,
        OwnerId = myUser.Id,
        ActivityDate = System.today()+1,
        WhoId = myContact.Id));
   insert newTask;
   System.debug('New Task Object: ' + newTask);
  }
  catch (QueryException e)
  {
   System.debug('Contact Query issue: ' + e);
  }        
  emailResult.success = true;
  return emailResult;
 }
 

 static testMethod void testTasks()
 {
     Messaging.InboundEmail email = new Messaging.InboundEmail();
     Messaging.InboundEnvelope env = new Messaging.InboundEnvelope();

  // Create the plainTextBody and fromAddres for the test
  email.plainTextBody = 'Here is my plainText body of the email #myEmailAddress@someDomain.com';
  email.fromAddress ='myEmailAddress@someDomain.com';

  TaskFromEmail taskObj = new TaskFromEmail();
  taskObj.handleInboundEmail(email, env);
 } 
                
}