Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * Copyright 2010-2013 Ning, Inc.
   * Copyright 2014 Groupon, Inc
   * Copyright 2014 The Billing Project, LLC
   *
   * The Billing Project licenses this file to you under the Apache License, version 2.0
   * (the "License"); you may not use this file except in compliance with the
   * License.  You may obtain a copy of the License at:
   *
  *    http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
  * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.  See the
  * License for the specific language governing permissions and limitations
  * under the License.
  */
 
 package org.killbill.billing.beatrix.integration.osgi;
 
 import java.io.File;
 import  java.nio.file.FileSystems;
 import  java.nio.file.Files;
 import  java.nio.file.NoSuchFileException;
 import  java.nio.file.Path;
 import  java.nio.file.Paths;
 import java.util.UUID;
 
 
 
 public class TestJrubyNotificationPlugin extends TestOSGIBase {
 
     private static final String BUNDLE_TEST_RESOURCE_PREFIX = "killbill-notification-test";
     private static final String BUNDLE_TEST_RESOURCE =  + ".tar.gz";
     private static final Path MAGIC_FILE_PATH = Paths.get(FileSystems.getDefault().getSeparator() + "var""tmp""killbill-notification-test.txt");
 
     @BeforeClass(groups = "slow")
     public void beforeClass() throws Exception {
         super.beforeClass();
 
         final String killbillVersion = System.getProperty("killbill.version");
         final SetupBundleWithAssertion setupTest = new SetupBundleWithAssertion(killbillVersion);
         setupTest.setupJrubyBundle();
     }
 
     @BeforeMethod(groups = "slow")
     @Override
     public void beforeMethod() throws Exception {
         super.beforeMethod();
 
         try {
             cleanupMagicFile();
         } catch (final NoSuchFileException ignored) {
         }
     }
 
     @AfterMethod(groups = "slow")
     @Override
     public void afterMethod() throws Exception {
         super.afterMethod();
 
         Assert.assertFalse(Files.exists());
     }
 
     @Test(groups = "slow")
     public void testOnEventForAccountCreation() throws Exception {
         final UUID objectId = UUID.randomUUID();
         final UUID accountId = UUID.randomUUID();
         final UUID tenantId = UUID.randomUUID();
 
         // Post ACCOUNT_CREATION event
         final ExternalBusTestEvent firstEvent = new ExternalBusTestEvent(objectId..accountIdtenantId, 0L, 1L, UUID.randomUUID());
         .post(firstEvent);
 
         // The plugin should have created a TAG_CREATION event
 
         // Post ACCOUNT_CHANGE event
         final ExternalBusTestEvent secondEvent = new ExternalBusTestEvent(objectId..accountIdtenantId, 0L, 1L, UUID.randomUUID());
         .post(secondEvent);
 
         // The plugin should have created a TAG_DELETION event
         checkThePluginGotTheEvent(secondEvent.);
     }
 
    private void checkThePluginGotTheEvent(final ExtBusEvent extBusEventfinal ExtBusEventType expectedEventTypethrows Exception {
        Awaitility.await()
                  .until(new Callable<Boolean>() {
                      @Override
                      public Boolean call() throws Exception {
                          return Files.exists();
                      }
                  });
        final String actualContent = com.google.common.io.Files.toString(new File(.toUri()), .);
        final String expectedContent = String.format("%s-%s-%s-%s-%s\n"expectedEventType.extBusEvent.getObjectId(), extBusEvent.getAccountId(), extBusEvent.getTenantId());
        Assert.assertEquals(actualContentexpectedContent);
        cleanupMagicFile();
    }
    private void cleanupMagicFile() throws IOException {
        Files.delete();
    }
New to GrepCode? Check out our FAQ X