gistfile1.txt

package match.activity.plug.dao;

import com.github.springtestdbunit.annotation.DatabaseSetup;
import com.github.springtestdbunit.annotation.DbUnitConfiguration;
import com.google.common.collect.ImmutableMap;
import com.jolbox.bonecp.BoneCPConfig;
import com.jolbox.bonecp.BoneCPDataSource;
import magnet.support.mail.queue.config.EnableMailQueue;
import magnet.support.mail.queue.config.MailQueueConfigurer;
import magnet.support.mail.queue.entity.MailQueueEntity;
import magnet.support.mail.queue.service.MailQueueService;
import match.web.datasourcehub.configuration.DataSourceConfiguration;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

import javax.naming.NamingException;
import javax.sql.DataSource;

import java.util.Map;

import static junit.framework.Assert.assertNotNull;

/**
 * @author nyilmaz
 */
@RunWith(SpringJUnit4ClassRunner.class)
@DbUnitConfiguration(databaseConnection = "masterDS")
@ContextConfiguration(classes = {
                                   DataSourceConfiguration.class,
                                   adsads.conf.class
})
public class adsads {

   @Autowired
   MailQueueService mailQueueService;

   @DatabaseSetup(value = "/testdata/mail.xml")
   @Test
   public void deneme () {

      assertNotNull(mailQueueService);
      MailQueueEntity entity = new MailQueueEntity();
      entity.setMailId(1);
      entity.setForced(false);
      entity.setEmail("asdasda");
      entity.setUserId(1);
      Map<String, Object> vars = ImmutableMap.of("deneme", (Object)"asdasda");
      entity.setVariables(vars);
      mailQueueService.enqueue(entity);

   }

   @Configuration
   @EnableMailQueue
   static class conf extends MailQueueConfigurer {

      @Override
      public DataSource getDataSource() {
         BoneCPDataSource dataSource = new BoneCPDataSource();
         dataSource.setUsername("testuser");
         dataSource.setPassword("reload");
         dataSource.setJdbcUrl("jdbc:mysql://masterdb.magnetdigital.local/mydating");
         dataSource.setDriverClass("com.mysql.jdbc.Driver");
         return dataSource;
      }
   }

}